code: @Override
    public CloseableHttpResponse waitForResponse(ListenableFuture<CloseableHttpResponse> responseFuture) {
      try {
        return responseFuture.get();
      } catch (InterruptedException | ExecutionException e) {
        throw new RuntimeException(e);
      }
    }
docs: Default implementation is to use HttpClients socket timeout which is waiting based on elapsed time between
  last packet sent from client till receive it from server.
  
  {@inheritDoc}
  @see org.apache.gobblin.writer.http.HttpWriterDecoration#waitForResponse(com.google.common.util.concurrent.ListenableFuture)