| requestUpstream() |   | 42% | | 62% | 3 | 5 | 6 | 14 | 0 | 1 |
| onError(Throwable) | | 85% | | 66% | 3 | 7 | 4 | 32 | 0 | 1 |
| close(Object) | | 26% | | 50% | 2 | 3 | 5 | 8 | 0 | 1 |
| lambda$onNext$3() | | 56% | | 50% | 1 | 2 | 1 | 5 | 0 | 1 |
| isChannelClosed() | | 0% | | 0% | 3 | 3 | 2 | 2 | 1 | 1 |
| lambda$onError$4(int, Long) | | 63% | | 50% | 1 | 2 | 1 | 6 | 0 | 1 |
| dispose() | | 75% | | 50% | 2 | 4 | 1 | 9 | 0 | 1 |
| onSubscribe(Subscription) | | 77% | | 50% | 1 | 2 | 1 | 5 | 0 | 1 |
| lambda$onError$5(Throwable, AmqpChannelProcessor.ChannelSubscriber) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| lambda$onComplete$6(AmqpChannelProcessor.ChannelSubscriber) | | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
| subscribe(CoreSubscriber) | | 100% | | 100% | 0 | 5 | 0 | 20 | 0 | 1 |
| onNext(Object) | | 100% | | 100% | 0 | 2 | 0 | 17 | 0 | 1 |
| AmqpChannelProcessor(String, String, Function, AmqpRetryPolicy, ClientLogger) | | 100% | | n/a | 0 | 1 | 0 | 14 | 0 | 1 |
| onComplete() | | 100% | | n/a | 0 | 1 | 0 | 10 | 0 | 1 |
| lambda$onNext$1(AmqpEndpointState) | | 100% | | 100% | 0 | 2 | 0 | 4 | 0 | 1 |
| setAndClearChannel() | | 100% | | n/a | 0 | 1 | 0 | 6 | 0 | 1 |
| lambda$onNext$2(Throwable) | | 100% | | n/a | 0 | 1 | 0 | 3 | 0 | 1 |
| static {...} | | 100% | | n/a | 0 | 1 | 0 | 2 | 0 | 1 |
| isDisposed() | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
| lambda$onNext$0(Object, AmqpChannelProcessor.ChannelSubscriber) | | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |