receiveFromPartition(String, int, EventPosition, Duration, ReceiveOptions) | | 0% | | 0% | 9 | 9 | 16 | 16 | 1 | 1 |
receiveFromPartition(String, int, EventPosition, Duration) | | 0% | | 0% | 8 | 8 | 14 | 14 | 1 | 1 |
queueWork(String, int, EventPosition, Duration, ReceiveOptions, FluxSink) | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
EventHubConsumerClient(EventHubConsumerAsyncClient, Duration) | | 0% | | n/a | 1 | 1 | 8 | 8 | 1 | 1 |
lambda$receiveFromPartition$0(String, int, EventPosition, Duration, FluxSink) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getPartitionProperties(String) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
lambda$receiveFromPartition$1(String, int, EventPosition, Duration, ReceiveOptions, FluxSink) | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
getEventHubProperties() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
receiveFromPartition(String, int, EventPosition) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getPartitionIds() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getFullyQualifiedNamespace() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getEventHubName() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
getConsumerGroup() | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
close() | | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |