source: class NetworkConnectionTest {
  
      private static final NoOpResponseHandler NO_OP_HANDLER;
      private ExecutorService executor;
      private EventLoop eventLoop;
  
      @Test
      void shouldCompleteResetFutureWhenSuccessResponseArrives()
      {
  
target:         EmbeddedChannel channel = newChannel();
          NetworkConnection connection = newConnection( channel );
  
          CompletableFuture<Void> resetFuture = connection.reset().toCompletableFuture();
          channel.runPendingTasks();
          assertFalse( resetFuture.isDone() );
  
          messageDispatcher( channel ).handleSuccessMessage( emptyMap() );
          assertTrue( resetFuture.isDone() );
          assertFalse( resetFuture.isCompletedExceptionally() );
      }
  
  }