本文整理了Java中org.eclipse.jetty.client.api.Response.abort方法的一些代码示例，展示了Response.abort的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Response.abort方法的具体详情如下：
包路径：org.eclipse.jetty.client.api.Response
类名称：Response
方法名：abort

Response.abort介绍

[英]Attempts to abort the receive of this response.
[中]试图中止接收此响应。

代码示例

代码示例来源：origin: spring-projects/spring-framework

@Override
public void onContent(Response response, ByteBuffer buffer) {
  while (true) {
    if (this.sockJsSession.isDisconnected()) {
      if (logger.isDebugEnabled()) {
        logger.debug("SockJS sockJsSession closed, closing response.");
      }
      response.abort(new SockJsException("Session closed.", this.sockJsSession.getId(), null));
      return;
    }
    if (buffer.remaining() == 0) {
      break;
    }
    int b = buffer.get();
    if (b == '\n') {
      handleFrame();
    }
    else {
      this.outputStream.write(b);
    }
  }
}

代码示例来源：origin: spring-projects/spring-framework

@Override
public void onBegin(Response response) {
  if (response.getStatus() != 200) {
    HttpStatus status = HttpStatus.valueOf(response.getStatus());
    response.abort(new HttpServerErrorException(status, "Unexpected XHR receive status"));
  }
}

代码示例来源：origin: org.eclipse.jetty/jetty-client

@Override
public boolean abort(Throwable cause)
{
  return response.abort(cause);
}

代码示例来源：origin: org.eclipse.jetty/jetty-proxy

@Override
  public void onError(Throwable failure)
  {
    proxyResponse.abort(failure);
  }
}

代码示例来源：origin: com.ovea.tajin.servers/tajin-server-jetty9

@Override
public boolean abort(Throwable cause)
{
  return response.abort(cause);
}

代码示例来源：origin: com.ovea.tajin.server/tajin-server-jetty9

@Override
public boolean abort(Throwable cause)
{
  return response.abort(cause);
}

代码示例来源：origin: com.ovea.tajin.servers/tajin-server-jetty9

@Override
public void onContent(Response response, ByteBuffer content)
{
  long newLength = buffer.length + content.remaining();
  if (newLength > maxLength)
    response.abort(new IllegalArgumentException("Buffering capacity exceeded"));
  byte[] newBuffer = new byte[(int)newLength];
  System.arraycopy(buffer, 0, newBuffer, 0, buffer.length);
  content.get(newBuffer, buffer.length, content.remaining());
  buffer = newBuffer;
}

代码示例来源：origin: com.ovea.tajin.server/tajin-server-jetty9

@Override
public void onContent(Response response, ByteBuffer content)
{
  long newLength = buffer.length + content.remaining();
  if (newLength > maxLength)
    response.abort(new IllegalArgumentException("Buffering capacity exceeded"));
  byte[] newBuffer = new byte[(int)newLength];
  System.arraycopy(buffer, 0, newBuffer, 0, buffer.length);
  content.get(newBuffer, buffer.length, content.remaining());
  buffer = newBuffer;
}

代码示例来源：origin: org.eclipse.jetty/jetty-proxy

@Override
  public void failed(Throwable x)
  {
    super.failed(x);
    proxyResponse.abort(x);
  }
});

代码示例来源：origin: org.eclipse.jetty/jetty-proxy

@Override
  public void onError(Throwable failure)
  {
    DeferredContentProvider.Chunk chunk = this.chunk;
    if (chunk != null)
      chunk.callback.failed(failure);
    else
      serverResponse.abort(failure);
  }
}

代码示例来源：origin: org.eclipse.jetty/jetty-client

@Override
public void onContent(Response response, ByteBuffer content)
{
  int length = content.remaining();
  if (length > BufferUtil.space(buffer))
  {
    int requiredCapacity = buffer == null ? length : buffer.capacity() + length;
    if (requiredCapacity > maxLength)
      response.abort(new IllegalArgumentException("Buffering capacity " + maxLength + " exceeded"));
    int newCapacity = Math.min(Integer.highestOneBit(requiredCapacity) << 1, maxLength);
    buffer = BufferUtil.ensureCapacity(buffer, newCapacity);
  }
  BufferUtil.append(buffer, content);
}

代码示例来源：origin: airlift/airlift

@Override
public synchronized void onContent(Response response, ByteBuffer content)
{
  int length = content.remaining();
  size += length;
  if (size > maxLength) {
    response.abort(new ResponseTooLargeException());
    return;
  }
  while (length > 0) {
    if (currentBufferPosition >= currentBuffer.length) {
      allocateCurrentBuffer();
    }
    int readLength = min(length, currentBuffer.length - currentBufferPosition);
    content.get(currentBuffer, currentBufferPosition, readLength);
    length -= readLength;
    currentBufferPosition += readLength;
  }
}

代码示例来源：origin: com.proofpoint.platform/http-client

@Override
public synchronized void onContent(Response response, ByteBuffer content)
{
  int length = content.remaining();
  size += length;
  if (size > maxLength) {
    response.abort(new ResponseTooLargeException());
    return;
  }
  while (length > 0) {
    if (currentBufferPosition >= currentBuffer.length) {
      allocateCurrentBuffer();
    }
    int readLength = min(length, currentBuffer.length - currentBufferPosition);
    content.get(currentBuffer, currentBufferPosition, readLength);
    length -= readLength;
    currentBufferPosition += readLength;
  }
}

代码示例来源：origin: com.ovea.tajin.servers/tajin-server-jetty9

@Override
public void onHeaders(Response response)
{
  HttpFields headers = response.getHeaders();
  long length = headers.getLongField(HttpHeader.CONTENT_LENGTH.asString());
  if (length > maxLength)
    response.abort(new IllegalArgumentException("Buffering capacity exceeded"));
  String contentType = headers.get(HttpHeader.CONTENT_TYPE);
  if (contentType != null)
  {
    String charset = "charset=";
    int index = contentType.toLowerCase(Locale.ENGLISH).indexOf(charset);
    if (index > 0)
    {
      String encoding = contentType.substring(index + charset.length());
      // Sometimes charsets arrive with an ending semicolon
      index = encoding.indexOf(';');
      if (index > 0)
        encoding = encoding.substring(0, index);
      this.encoding = encoding;
    }
  }
}

代码示例来源：origin: org.springframework/spring-websocket

@Override
public void onContent(Response response, ByteBuffer buffer) {
  while (true) {
    if (this.sockJsSession.isDisconnected()) {
      if (logger.isDebugEnabled()) {
        logger.debug("SockJS sockJsSession closed, closing response.");
      }
      response.abort(new SockJsException("Session closed.", this.sockJsSession.getId(), null));
      return;
    }
    if (buffer.remaining() == 0) {
      break;
    }
    int b = buffer.get();
    if (b == '\n') {
      handleFrame();
    }
    else {
      this.outputStream.write(b);
    }
  }
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public void onContent(Response response, ByteBuffer buffer) {
  while (true) {
    if (this.sockJsSession.isDisconnected()) {
      if (logger.isDebugEnabled()) {
        logger.debug("SockJS sockJsSession closed, closing response.");
      }
      response.abort(new SockJsException("Session closed.", this.sockJsSession.getId(), null));
      return;
    }
    if (buffer.remaining() == 0) {
      break;
    }
    int b = buffer.get();
    if (b == '\n') {
      handleFrame();
    }
    else {
      this.outputStream.write(b);
    }
  }
}

代码示例来源：origin: airlift/airlift

@Override
public synchronized void onHeaders(Response response)
{
  long length = response.getHeaders().getLongField(HttpHeader.CONTENT_LENGTH.asString());
  if (length > maxLength) {
    response.abort(new ResponseTooLargeException());
  }
}

代码示例来源：origin: com.proofpoint.platform/http-client

@Override
public synchronized void onHeaders(Response response)
{
  long length = response.getHeaders().getLongField(HttpHeader.CONTENT_LENGTH.asString());
  if (length > maxLength) {
    response.abort(new ResponseTooLargeException());
  }
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public void onBegin(Response response) {
  if (response.getStatus() != 200) {
    HttpStatus status = HttpStatus.valueOf(response.getStatus());
    response.abort(new HttpServerErrorException(status, "Unexpected XHR receive status"));
  }
}

代码示例来源：origin: org.springframework/spring-websocket

@Override
public void onBegin(Response response) {
  if (response.getStatus() != 200) {
    HttpStatus status = HttpStatus.valueOf(response.getStatus());
    response.abort(new HttpServerErrorException(status, "Unexpected XHR receive status"));
  }
}