code: @Override
      public synchronized void stop(final StopContext context) {
          Runnable r = new Runnable() {
              @Override
              public void run() {
                  try {
                      StreamUtils.safeClose(connection);
                      responseAttachmentSupport.shutdown();
                  } finally {
                      context.complete();
                  }
              }
          };
          try {
              executor.execute(r);
          } catch (RejectedExecutionException e) {
              r.run();
          } finally {
              context.asynchronous();
          }
      }
docs: {@inheritDoc}