@Test public void cancellingOnCloseShouldNotCancelFuture() { fixture.onClose().afterOnSubscribe(Cancellable::cancel).subscribe(); verify(channelCloseFuture, never()).cancel(anyBoolean()); }
@Override public final Completable onClose() { return onClose; }
NettyChannelListenableAsyncCloseable implements ListenableAsyncCloseable { @Override public final Completable onClose() { return onClose; } }
NettyChannelListenableAsyncCloseable implements ListenableAsyncCloseable { @Override public final Completable onClose() { return onClose; } NettyChannelListenableAsyncCloseable(Channel channel, Executor offloadingExecutor); }
NettyChannelListenableAsyncCloseable implements ListenableAsyncCloseable { @Override public final Completable onClose() { return onClose; } NettyChannelListenableAsyncCloseable(Channel channel, Executor offloadingExecutor); @Override final Completable closeAsync(); @Override final Completable closeAsyncGracefully(); @Override final Completable onClose(); }
NettyChannelListenableAsyncCloseable implements ListenableAsyncCloseable { @Override public final Completable onClose() { return onClose; } NettyChannelListenableAsyncCloseable(Channel channel, Executor offloadingExecutor); @Override final Completable closeAsync(); @Override final Completable closeAsyncGracefully(); @Override final Completable onClose();  }