onMessageComplete(Future, StreamMessage) |   | 14% |   | 25% | 2 | 3 | 4 | 7 | 0 | 1 |
lambda$sendMessage$0(StreamMessage, IntFunction) |   | 46% |   | 50% | 1 | 2 | 2 | 7 | 0 | 1 |
sendMessage(StreamingChannel, StreamMessage) |   | 71% |   | 80% | 2 | 6 | 6 | 16 | 0 | 1 |
sendControlMessage(StreamMessage) |   | 42% | | n/a | 0 | 1 | 4 | 6 | 0 | 1 |
unsafeCloseControlChannel() |  | 0% | | n/a | 1 | 1 | 3 | 3 | 1 | 1 |
StreamingMultiplexedChannel(StreamSession, StreamingChannel.Factory, InetAddressAndPort, StreamingChannel, int) |   | 92% |   | 50% | 1 | 2 | 0 | 14 | 0 | 1 |
setClosed() |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
setControlChannel(NettyStreamingChannel) |  | 0% | | n/a | 1 | 1 | 2 | 2 | 1 | 1 |
semaphoreAvailablePermits() |  | 0% | | n/a | 1 | 1 | 1 | 1 | 1 | 1 |
createControlChannel() |   | 97% |   | 50% | 1 | 2 | 0 | 8 | 0 | 1 |
scheduleKeepAliveTask(StreamingChannel) |   | 95% |   | 66% | 2 | 4 | 2 | 14 | 0 | 1 |
connected() |   | 92% |   | 50% | 3 | 4 | 0 | 1 | 0 | 1 |
close() |  | 100% |  | 100% | 0 | 4 | 0 | 12 | 0 | 1 |
createFileChannel(InetAddressAndPort) |  | 100% |  | 100% | 0 | 2 | 0 | 5 | 0 | 1 |
static {...} |  | 100% | | n/a | 0 | 1 | 0 | 4 | 0 | 1 |
connectedTo() |  | 100% |  | 100% | 0 | 2 | 0 | 1 | 0 | 1 |
setupControlMessageChannel() |  | 100% |  | 100% | 0 | 2 | 0 | 3 | 0 | 1 |
lambda$sendMessage$1(StreamMessage, Future) |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |
peer() |  | 100% | | n/a | 0 | 1 | 0 | 1 | 0 | 1 |