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

Buffer.newInstance介绍

暂无

代码示例

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Create a new buffer from a byte[]. The byte[] will be copied to form the buffer.
 * @param bytes the byte array
 * @return the buffer
 */
public static io.vertx.rxjava.core.buffer.Buffer buffer(byte[] bytes) { 
 io.vertx.rxjava.core.buffer.Buffer ret = io.vertx.rxjava.core.buffer.Buffer.newInstance(io.vertx.core.buffer.Buffer.buffer(bytes));
 return ret;
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Create a new, empty buffer.
 * @return the buffer
 */
public static io.vertx.rxjava.core.buffer.Buffer buffer() { 
 io.vertx.rxjava.core.buffer.Buffer ret = io.vertx.rxjava.core.buffer.Buffer.newInstance(io.vertx.core.buffer.Buffer.buffer());
 return ret;
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Create a new buffer given the initial size hint.
 * <p>
 * If you know the buffer will require a certain size, providing the hint can prevent unnecessary re-allocations
 * as the buffer is written to and resized.
 * @param initialSizeHint the hint, in bytes
 * @return the buffer
 */
public static io.vertx.rxjava.core.buffer.Buffer buffer(int initialSizeHint) { 
 io.vertx.rxjava.core.buffer.Buffer ret = io.vertx.rxjava.core.buffer.Buffer.newInstance(io.vertx.core.buffer.Buffer.buffer(initialSizeHint));
 return ret;
}

代码示例来源：origin: vert-x3/vertx-rx

/**
 * Create a new buffer from a byte[]. The byte[] will be copied to form the buffer.
 * @param bytes the byte array
 * @return the buffer
 */
public static io.vertx.rxjava.core.buffer.Buffer buffer(byte[] bytes) { 
 io.vertx.rxjava.core.buffer.Buffer ret = io.vertx.rxjava.core.buffer.Buffer.newInstance(io.vertx.core.buffer.Buffer.buffer(bytes));
 return ret;
}

代码示例来源：origin: io.vertx/vertx-rx-java

public void handle(AsyncResult<io.vertx.core.buffer.Buffer> ar) {
  if (ar.succeeded()) {
   handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.rxjava.core.buffer.Buffer.newInstance(ar.result())));
  } else {
   handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
  }
 }
});

代码示例来源：origin: io.vertx/vertx-rx-java

public void handle(AsyncResult<io.vertx.core.buffer.Buffer> ar) {
  if (ar.succeeded()) {
   pongHandler.handle(io.vertx.core.Future.succeededFuture(io.vertx.rxjava.core.buffer.Buffer.newInstance(ar.result())));
  } else {
   pongHandler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
  }
 }
});

代码示例来源：origin: io.vertx/vertx-rx-java

public void handle(AsyncResult<io.vertx.core.buffer.Buffer> ar) {
  if (ar.succeeded()) {
   handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.rxjava.core.buffer.Buffer.newInstance(ar.result())));
  } else {
   handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
  }
 }
});

代码示例来源：origin: io.vertx/vertx-rx-java

public void handle(AsyncResult<io.vertx.core.buffer.Buffer> ar) {
  if (ar.succeeded()) {
   handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.rxjava.core.buffer.Buffer.newInstance(ar.result())));
  } else {
   handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
  }
 }
});

代码示例来源：origin: io.vertx/vertx-rx-java

public void handle(AsyncResult<io.vertx.core.buffer.Buffer> ar) {
  if (ar.succeeded()) {
   handler.handle(io.vertx.core.Future.succeededFuture(io.vertx.rxjava.core.buffer.Buffer.newInstance(ar.result())));
  } else {
   handler.handle(io.vertx.core.Future.failedFuture(ar.cause()));
  }
 }
});

代码示例来源：origin: reactiverse/reactive-pg-client

/**
 * Get a buffer value at <code>pos</code>.
 * @param name the column
 * @return the value or <code>null</code>
 */
public io.vertx.rxjava.core.buffer.Buffer getBuffer(String name) { 
 io.vertx.rxjava.core.buffer.Buffer ret = io.vertx.rxjava.core.buffer.Buffer.newInstance(delegate.getBuffer(name));
 return ret;
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Returns a slice of this buffer. Modifying the content
 * of the returned buffer or this buffer affects each other's content
 * while they maintain separate indexes and marks.
 * @return 
 */
public io.vertx.rxjava.core.buffer.Buffer slice() { 
 io.vertx.rxjava.core.buffer.Buffer ret = io.vertx.rxjava.core.buffer.Buffer.newInstance(delegate.slice());
 return ret;
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * @return Get the entire HTTP request body as a . The context must have first been routed to a {@link io.vertx.rxjava.ext.web.handler.BodyHandler} for this to be populated.
 */
public io.vertx.rxjava.core.buffer.Buffer getBody() { 
 io.vertx.rxjava.core.buffer.Buffer ret = io.vertx.rxjava.core.buffer.Buffer.newInstance(delegate.getBody());
 return ret;
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Returns a copy of a sub-sequence the Buffer as a {@link io.vertx.rxjava.core.buffer.Buffer} starting at position <code>start</code>
 * and ending at position <code>end - 1</code>
 * @param start 
 * @param end 
 * @return 
 */
public io.vertx.rxjava.core.buffer.Buffer getBuffer(int start, int end) { 
 io.vertx.rxjava.core.buffer.Buffer ret = io.vertx.rxjava.core.buffer.Buffer.newInstance(delegate.getBuffer(start, end));
 return ret;
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * @return the frame payload
 */
public io.vertx.rxjava.core.buffer.Buffer payload() { 
 if (cached_2 != null) {
  return cached_2;
 }
 io.vertx.rxjava.core.buffer.Buffer ret = io.vertx.rxjava.core.buffer.Buffer.newInstance(delegate.payload());
 cached_2 = ret;
 return ret;
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * @return the buffer value
 */
public io.vertx.rxjava.core.buffer.Buffer value() { 
 if (cached_1 != null) {
  return cached_1;
 }
 io.vertx.rxjava.core.buffer.Buffer ret = io.vertx.rxjava.core.buffer.Buffer.newInstance(delegate.value());
 cached_1 = ret;
 return ret;
}

代码示例来源：origin: reactiverse/reactive-pg-client

/**
 * Get a buffer value at <code>pos</code>.
 * @param pos the position
 * @return the value or <code>null</code>
 */
public io.vertx.rxjava.core.buffer.Buffer getBuffer(int pos) { 
 io.vertx.rxjava.core.buffer.Buffer ret = io.vertx.rxjava.core.buffer.Buffer.newInstance(delegate.getBuffer(pos));
 return ret;
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Return the binary value.
 * <p>
 * JSON itself has no notion of a binary, this extension complies to the RFC-7493, so this method assumes there is a
 * String value with the key and it contains a Base64 encoded binary, which it decodes if found and returns.
 * @return the binary value or <code>null</code> if the event has no JSON value
 */
public io.vertx.rxjava.core.buffer.Buffer binaryValue() { 
 io.vertx.rxjava.core.buffer.Buffer ret = io.vertx.rxjava.core.buffer.Buffer.newInstance(delegate.binaryValue());
 return ret;
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * @return the response body decoded as a , or <code>null</code> if a codec other than  was used
 */
public io.vertx.rxjava.core.buffer.Buffer bodyAsBuffer() { 
 if (cached_7 != null) {
  return cached_7;
 }
 io.vertx.rxjava.core.buffer.Buffer ret = io.vertx.rxjava.core.buffer.Buffer.newInstance(delegate.bodyAsBuffer());
 cached_7 = ret;
 return ret;
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Returns the data of the {@link io.vertx.rxjava.core.datagram.DatagramPacket}
 * @return the data
 */
public io.vertx.rxjava.core.buffer.Buffer data() { 
 io.vertx.rxjava.core.buffer.Buffer ret = io.vertx.rxjava.core.buffer.Buffer.newInstance(delegate.data());
 return ret;
}

代码示例来源：origin: io.vertx/vertx-rx-java

/**
 * Blocking version of {@link io.vertx.rxjava.core.file.FileSystem#readFile}
 * @param path 
 * @return 
 */
public io.vertx.rxjava.core.buffer.Buffer readFileBlocking(String path) { 
 io.vertx.rxjava.core.buffer.Buffer ret = io.vertx.rxjava.core.buffer.Buffer.newInstance(delegate.readFileBlocking(path));
 return ret;
}