import org.eclipse.jetty.client.util.InputStreamResponseListener; //导入依赖的package包/类
public Map<String, Transaction> getTransactions(String accountId, int offset, int transactionsPerRequest, boolean ignoreException)
{
  Map<String, Transaction> transactionLookup = null;
  try
  {
    InputStreamResponseListener listener = new InputStreamResponseListener();

    Request request = httpClient.POST(BURST_API_URL)
      .param("requestType", "getAccountTransactions")
      .param("firstIndex", String.valueOf(offset))
      .param("lastIndex", String.valueOf(offset + transactionsPerRequest))
      .param("account", accountId);
    request.send(listener);

    Response response = listener.get(BurstcoinFaucetProperties.getConnectionTimeout(), TimeUnit.MILLISECONDS);
    transactionLookup = handleGetTransactionsResponse(listener, response, ignoreException);
  }
  catch(Exception e)
  {
    LOG.warn("Error: Failed to 'getAccountTransactions' for accountId '" + accountId + "' : " + e.getMessage());
  }
  return transactionLookup;
}
 

import org.eclipse.jetty.client.util.InputStreamResponseListener; //导入依赖的package包/类
public static BloomFilter fromUrl(String url) throws Exception
{
    log.info("Loading bloom filter from " + url);

    Request request = BloomFilterScalarFunctions.HTTP_CLIENT.newRequest(url);
    request.method("GET");
    InputStreamResponseListener listener = new InputStreamResponseListener();
    request.send(listener);

    // Wait for the response headers to arrive
    Response response = listener.get(10, TimeUnit.SECONDS);

    // Look at the response
    if (response.getStatus() == 200) {
        // Use try-with-resources to close input stream.
        try (InputStream responseContent = listener.getInputStream()) {
            byte[] bytes = ByteStreams.toByteArray(responseContent);
            return newInstance(bytes);
        }
    }
    log.warn("Non-200 response status " + response.getStatus());
    return null;
}
 

import org.eclipse.jetty.client.util.InputStreamResponseListener; //导入依赖的package包/类
private void fireResponse(CapturingRequest request, int errorCode, String responseText, int resultSize, ObservableObserver observer, boolean successfulResponse) throws InterruptedException {
    Response.CompleteListener listener = request.awaitSend(1000, TimeUnit.MILLISECONDS);
    assertNotNull(listener);
    InputStreamResponseListener responseListener = (InputStreamResponseListener) listener;

    Result result = mock(Result.class);
    Response response = mock(Response.class);
    when(result.getResponse()).thenReturn(response);
    when(result.isSucceeded()).thenReturn(successfulResponse);
    when(result.isFailed()).thenReturn(!successfulResponse);
    HttpFields headers = mock(HttpFields.class);
    when(response.getHeaders()).thenReturn(headers);
    when(headers.get(HttpHeader.CONTENT_LENGTH)).thenReturn(String.valueOf(resultSize));
    when(response.getStatus()).thenReturn(errorCode);
    when(response.getVersion()).thenReturn(HttpVersion.HTTP_1_1);

    // fire that event
    responseListener.onHeaders(response);
    responseListener.onContent(response, ByteBuffer.allocate(0));
    responseListener.onComplete(result);

    assertTrue(observer.getLatch().await(1000, TimeUnit.MILLISECONDS));
}
 

import org.eclipse.jetty.client.util.InputStreamResponseListener; //导入依赖的package包/类
private Map<String, Transaction> handleGetTransactionsResponse(InputStreamResponseListener listener, Response response, boolean ignoreException)
{
  Map<String, Transaction> transactionLookup = new HashMap<>();
  // Look at the response
  if(response.getStatus() == 200)
  {
    // Use try-with-resources to close input stream.
    try (InputStream responseContent = listener.getInputStream())
    {
      Transactions transactions = objectMapper.readValue(responseContent, Transactions.class);
      LOG.info("received '" + transactions.getTransactions().size() + "' transactions in '" + transactions.getRequestProcessingTime() + "' ms");
      transactionLookup = new HashMap<>();
      for(Transaction transaction : transactions.getTransactions())
      {
        transactionLookup.put(transaction.getTransaction(), transaction);
      }
    }
    catch(Exception e)
    {
      // exception is ok for new accounts
      if(!ignoreException)
      {
        LOG.warn("Failed to receive faucet account transactions.", e);
      }
    }
  }
  return transactionLookup;
}
 

import org.eclipse.jetty.client.util.InputStreamResponseListener; //导入依赖的package包/类
/**
 * Fetch zeppelin instances for a given user.
 * @param ticket
 * @return
 * @throws IOException
 */
public List<Instance> getInstances(String ticket) throws IOException {
  InputStreamResponseListener listener = new InputStreamResponseListener();
  Response response;
  String url = zepelinhubUrl + "instances";
  String data;

  Request request = client.newRequest(url).header(USER_SESSION_HEADER, ticket);
  request.send(listener);

  try {
    response = listener.get(30, TimeUnit.SECONDS);
  } catch (InterruptedException | TimeoutException | ExecutionException e) {
    LOG.error("Cannot perform request to ZeppelinHub", e);
    throw new IOException("Cannot perform  GET request to ZeppelinHub", e);
  }

  int code = response.getStatus();
  if (code == 200) {
    try (InputStream responseContent = listener.getInputStream()) {
      data = IOUtils.toString(responseContent, "UTF-8");
    }
  } else {
    LOG.error("ZeppelinHub GET {} returned with status {} ", url, code);
    throw new IOException("Cannot perform  GET request to ZeppelinHub");
  }
  Type listType = new TypeToken<ArrayList<Instance>>() {}.getType();
  return new Gson().fromJson(data, listType);
}
 

import org.eclipse.jetty.client.util.InputStreamResponseListener; //导入依赖的package包/类
/**
 * Download the log files for Elasticsearch.
 *
 * <b>Important: the caller MUST close the ZipInputStream returned by
 * this method, otherwise all subsequent client/server communications
 * will be blocked.</b>
 *
 * @return A ZipInputStream for the log files. If an error occurred, the inputstream
 * may by empty or contain the server response. The caller MUST close this
 * ZipInputStream when they have finished with it.
 * @throws IOException If HTTP GET fails
 */
public ZipInputStream downloadElasticsearchLogs() throws IOException
{
    String url = String.format("%s/logs/elasticsearch", m_BaseUrl);

    LOGGER.debug("GET download logs " + url);

    m_LastError = null;
    InputStreamResponseListener responseListener = new InputStreamResponseListener();
    Request request = m_HttpClient.newRequest(url).method(HttpMethod.GET);
    request.send(responseListener);
    return new ZipInputStream(responseListener.getInputStream());
}
 

import org.eclipse.jetty.client.util.InputStreamResponseListener; //导入依赖的package包/类
/**
 * Download the log files for the Engine API.
 *
 * <b>Important: the caller MUST close the ZipInputStream returned by
 * this method, otherwise all subsequent client/server communications
 * will be blocked.</b>
 *
 * @return A ZipInputStream for the log files. If an error occurred, the inputstream
 * may by empty or contain the server response. The caller MUST close this
 * ZipInputStream when they have finished with it.
 * @throws IOException If HTTP GET fails
 */
public ZipInputStream downloadEngineLogs() throws IOException
{
    String url = String.format("%s/logs/engine_api", m_BaseUrl);

    LOGGER.debug("GET download logs " + url);

    m_LastError = null;
    InputStreamResponseListener responseListener = new InputStreamResponseListener();
    Request request = m_HttpClient.newRequest(url).method(HttpMethod.GET);
    request.send(responseListener);
    return new ZipInputStream(responseListener.getInputStream());
}
 

import org.eclipse.jetty.client.util.InputStreamResponseListener; //导入依赖的package包/类
/**
 * Download a support bundle file.
 *
 * <b>Important: the caller MUST close the ZipInputStream returned by
 * this method, otherwise all subsequent client/server communications
 * will be blocked.</b>
 *
 * @return A ZipInputStream for the log files. If an error occurred, the inputstream
 * may by empty or contain the server response. The caller MUST close this
 * ZipInputStream when they have finished with it.
 * @throws IOException If HTTP GET fails
 */
public ZipInputStream downloadSupportBundle() throws IOException
{
    String url = String.format("%s/support", m_BaseUrl);

    LOGGER.debug("GET support bundle " + url);

    m_LastError = null;
    InputStreamResponseListener responseListener = new InputStreamResponseListener();
    Request request = m_HttpClient.newRequest(url).method(HttpMethod.GET);
    request.send(responseListener);
    return new ZipInputStream(responseListener.getInputStream());
}
 

import org.eclipse.jetty.client.util.InputStreamResponseListener; //导入依赖的package包/类
@Override
public Response.Listener getListener()
{
    this.listener = new InputStreamResponseListener();
    return this.listener;
}
 

import org.eclipse.jetty.client.util.InputStreamResponseListener; //导入依赖的package包/类
public MarketoResponseJetty92EntityReader(long timeout, Class<T> resultClass)
{
    this.listener = new InputStreamResponseListener();
    this.timeout = timeout;
    this.javaType = OBJECT_MAPPER.getTypeFactory().constructParametrizedType(MarketoResponse.class, MarketoResponse.class, resultClass);
}
 

import org.eclipse.jetty.client.util.InputStreamResponseListener; //导入依赖的package包/类
public InputStream getResponseEntityStream( long size )
{
	final InputStreamResponseListener inputStreamResponseListener = getInputStreamResponseListener();
	return inputStreamResponseListener == null ? null : inputStreamResponseListener.getInputStream();
}
 

import org.eclipse.jetty.client.util.InputStreamResponseListener; //导入依赖的package包/类
/**
 * Download all the log files for the given job.
 *
 * <b>Important: the caller MUST close the ZipInputStream returned by
 * this method, otherwise all subsequent client/server communications
 * will be blocked.</b>
 *
 * @param jobId The Job's unique Id
 * @return A ZipInputStream for the log files. If an error occurred, the inputstream
 * may by empty or contain the server response. The caller MUST close this
 * ZipInputStream when they have finished with it.
 * @throws IOException If HTTP GET fails
 */
public ZipInputStream downloadAllLogs(String jobId) throws IOException
{
    String url = String.format("%s/logs/%s", m_BaseUrl, encode(jobId));

    LOGGER.debug("GET download logs " + url);

    m_LastError = null;
    InputStreamResponseListener responseListener = new InputStreamResponseListener();
    Request request = m_HttpClient.newRequest(url).method(HttpMethod.GET);
    request.send(responseListener);
    return new ZipInputStream(responseListener.getInputStream());
}
 

import org.eclipse.jetty.client.util.InputStreamResponseListener; //导入依赖的package包/类
/**
 * Returns the input stream response listener.
 * 
 * @return The input stream response listener.
 */
public InputStreamResponseListener getInputStreamResponseListener()
{
	return inputStreamResponseListener;
}