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

Buffers.wrap介绍

[英]Returns Buffer, which wraps the String.
[中]返回缓冲区，它包装字符串。

代码示例

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

@Override
public void write(int b) throws IOException {
  final byte[] buffer = new byte[1];
  buffer[0] = (byte) b;
  delegate.feed(Buffers.wrap(MemoryManager.DEFAULT_MEMORY_MANAGER, buffer), false);
}

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

@Override
public void write(byte[] b, int off, int len) throws IOException {
  delegate.feed(Buffers.wrap(MemoryManager.DEFAULT_MEMORY_MANAGER, b, off, len), false);
}

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

@Override
public void write(byte[] b) throws IOException {
  delegate.feed(Buffers.wrap(MemoryManager.DEFAULT_MEMORY_MANAGER, b), false);
}

代码示例来源：origin: com.ning/async-http-client

final byte[] data = sb.toString().getBytes(charset);
final MemoryManager mm = ctx.getMemoryManager();
final Buffer gBuffer = Buffers.wrap(mm, data);
final HttpContent content = requestPacket.httpContentBuilder()
    .content(gBuffer)

代码示例来源：origin: com.ning/async-http-client

@SuppressWarnings({"unchecked"})
public boolean generate(final FilterChainContext ctx,
           final Request request,
           final HttpRequestPacket requestPacket)
throws IOException {
  String charset = request.getBodyEncoding();
  if (charset == null) {
    charset = Charsets.ASCII_CHARSET.name();
  }
  final byte[] data = request.getStringData().getBytes(charset);
  final MemoryManager mm = ctx.getMemoryManager();
  final Buffer gBuffer = Buffers.wrap(mm, data);
  if (requestPacket.getContentLength() == -1) {
    requestPacket.setContentLengthLong(data.length);
  }
  final HttpContent content = requestPacket.httpContentBuilder()
      .content(gBuffer)
      .last(true)
      .build();
  ctx.write(content, ((!requestPacket.isCommitted())
      ? ctx.getTransportContext().getCompletionHandler()
      : null));
  return true;
}

代码示例来源：origin: com.ning/async-http-client

b = Buffers.wrap(mm, buf, 0, read);

代码示例来源：origin: com.ning/async-http-client

@SuppressWarnings({"unchecked"})
public boolean generate(final FilterChainContext ctx,
           final Request request,
           final HttpRequestPacket requestPacket)
throws IOException {
  final MemoryManager mm = ctx.getMemoryManager();
  final byte[] data = request.getByteData();
  final Buffer gBuffer = Buffers.wrap(mm, data);
  if (requestPacket.getContentLength() == -1) {
    requestPacket.setContentLengthLong(data.length);
  }
  final HttpContent content = requestPacket.httpContentBuilder()
      .content(gBuffer)
      .last(true)
      .build();
  
  ctx.write(content, ((!requestPacket.isCommitted())
      ? ctx.getTransportContext().getCompletionHandler()
      : null));
  return true;
}

代码示例来源：origin: org.glassfish.tyrus.tests/tyrus-test-tools

private void flushBufferedData() {
    if (buffer.size() == 0) {
      // buffer is empty
      return;
    }
    Buffer message = Buffers.wrap(grizzlyConnection.getMemoryManager(), buffer.toByteArray());
    grizzlyConnection.write(message);
    buffer.reset();
  }
}

代码示例来源：origin: eclipse-ee4j/tyrus

private void flushBufferedData() {
    if (buffer.size() == 0) {
      // buffer is empty
      return;
    }
    Buffer message = Buffers.wrap(grizzlyConnection.getMemoryManager(), buffer.toByteArray());
    grizzlyConnection.write(message);
    buffer.reset();
  }
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-http

public void allocate(final int size) {
  if (isNull() || (limit - start) < size) {
    setBufferChunk(Buffers.wrap(null, new byte[size]), 0, 0, size);
  }
  end = start;
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-http

/**
   * Sets the status and reason phrase on the specified response.
   * @param response the response to set the status and reason phrase on.
   */
  public void setValues(final HttpResponsePacket response) {
    response.setStatus(this);
    response.setReasonPhrase(Buffers.wrap(null, reasonPhraseBytes));
  }
}

代码示例来源：origin: javaee/grizzly

/**
 * {@inheritDoc}
 */
@Override
public void writeByteArray(byte[] data, int offset, int length) throws IOException {
  final Buffer buffer = Buffers.wrap(connection.getMemoryManager(),
      data, offset, length);
  output.write(buffer);
}

代码示例来源：origin: javaee/grizzly

public void allocate(final int size) {
  if (isNull() || (limit - start) < size) {
    setBufferChunk(Buffers.wrap(null, new byte[size]), 0, 0, size);
  }
  end = start;
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-core

/**
 * {@inheritDoc}
 */
@Override
public void writeByteArray(byte[] data, int offset, int length) throws IOException {
  final Buffer buffer = Buffers.wrap(connection.getMemoryManager(),
      data, offset, length);
  output.write(buffer);
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-websockets-server

/**
   * Sets the status and reason phrase on the specified response.
   * @param response the response to set the status and reason phrase on.
   */
  public void setValues(final HttpResponsePacket response) {
    response.setStatus(this);
    response.setReasonPhrase(Buffers.wrap(null, reasonPhraseBytes));
  }
}

代码示例来源：origin: javaee/grizzly

/**
 * {@inheritDoc}
 */
@Override
public void writeByteArray(byte[] data, int offset, int length) throws IOException {
  final Buffer buffer = Buffers.wrap(connection.getMemoryManager(),
      data, offset, length);
  output.write(buffer);
}

代码示例来源：origin: javaee/grizzly

/**
   * Sets the status and reason phrase on the specified response.
   * @param response the response to set the status and reason phrase on.
   */
  public void setValues(final HttpResponsePacket response) {
    response.setStatus(this);
    response.setReasonPhrase(Buffers.wrap(null, reasonPhraseBytes));
  }
}

代码示例来源：origin: javaee/grizzly

/**
   * Sets the status and reason phrase on the specified response.
   * @param response the response to set the status and reason phrase on.
   */
  public void setValues(final HttpResponsePacket response) {
    response.setStatus(this);
    response.setReasonPhrase(Buffers.wrap(null, reasonPhraseBytes));
  }
}

代码示例来源：origin: org.glassfish.main.web/web-core

@Override
public void replayPayload(byte[] payloadByteArray) {
  if (payloadByteArray == null) {
    return;
  }
  coyoteRequest.replayPayload(Buffers.wrap(
      coyoteRequest.getContext().getMemoryManager(), payloadByteArray));
}

代码示例来源：origin: org.glassfish.grizzly/grizzly-websockets-server

@SuppressWarnings("unchecked")
protected void sendRaw(byte[] rawData) {
  final Connection connection = protocolHandler.getConnection();
  final MemoryManager mm = connection.getTransport().getMemoryManager();
  final Buffer buffer = Buffers.wrap(mm, rawData);
  buffer.allowBufferDispose(false);
  connection.write(buffer);
}