| drainQueue() |   | 0% |   | 0% | 12 | 12 | 29 | 29 | 1 | 1 | 
| getOrUpdateCurrentWork() |   | 0% |   | 0% | 5 | 5 | 16 | 16 | 1 | 1 | 
| queueWork(SynchronousReceiveWork) |   | 0% |   | 0% | 3 | 3 | 11 | 11 | 1 | 1 | 
| SynchronousMessageSubscriber(SynchronousReceiveWork) |   | 0% |   | 0% | 2 | 2 | 13 | 13 | 1 | 1 | 
| requestUpstream(long) |   | 0% |   | 0% | 4 | 4 | 16 | 16 | 1 | 1 | 
| dispose(String, Throwable) |   | 0% |   | 0% | 4 | 4 | 13 | 13 | 1 | 1 | 
| lambda$getOrUpdateCurrentWork$0(long) |   | 0% |   | 0% | 3 | 3 | 8 | 8 | 1 | 1 | 
| hookOnSubscribe(Subscription) |   | 0% |   | 0% | 2 | 2 | 6 | 6 | 1 | 1 | 
| drain() |   | 0% |   | 0% | 3 | 3 | 8 | 8 | 1 | 1 | 
| isTerminated() |   | 0% |   | 0% | 2 | 2 | 3 | 3 | 1 | 1 | 
| static {...} |   | 0% |  | n/a | 1 | 1 | 4 | 4 | 1 | 1 | 
| hookOnNext(ServiceBusReceivedMessage) |   | 0% |  | n/a | 1 | 1 | 3 | 3 | 1 | 1 | 
| dispose() |   | 0% |  | n/a | 1 | 1 | 3 | 3 | 1 | 1 | 
| hookOnError(Throwable) |   | 0% |  | n/a | 1 | 1 | 2 | 2 | 1 | 1 | 
| getWorkQueueSize() |   | 0% |  | n/a | 1 | 1 | 1 | 1 | 1 | 1 | 
| hookOnCancel() |   | 0% |  | n/a | 1 | 1 | 2 | 2 | 1 | 1 |