### Question:
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();  }### Answer:
@Test public void cancellingOnCloseShouldNotCancelFuture() { fixture.onClose().afterOnSubscribe(Cancellable::cancel).subscribe(); verify(channelCloseFuture, never()).cancel(anyBoolean()); }