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