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

Buffer.newInstance介绍

暂无

代码示例

代码示例来源：origin: vietj/childprocess-vertx-ext

public void handle(io.vertx.core.buffer.Buffer event) {
  handler.handle(io.vertx.reactivex.core.buffer.Buffer.newInstance(event));
 }
});

代码示例来源：origin: io.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.reactivex.core.buffer.Buffer getBuffer(int pos) { 
 io.vertx.reactivex.core.buffer.Buffer ret = io.vertx.reactivex.core.buffer.Buffer.newInstance(delegate.getBuffer(pos));
 return ret;
}

代码示例来源：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.reactivex.core.buffer.Buffer getBuffer(String name) { 
 io.vertx.reactivex.core.buffer.Buffer ret = io.vertx.reactivex.core.buffer.Buffer.newInstance(delegate.getBuffer(name));
 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.reactivex.core.buffer.Buffer getBuffer(int pos) { 
 io.vertx.reactivex.core.buffer.Buffer ret = io.vertx.reactivex.core.buffer.Buffer.newInstance(delegate.getBuffer(pos));
 return ret;
}

代码示例来源：origin: io.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.reactivex.core.buffer.Buffer getBuffer(String name) { 
 io.vertx.reactivex.core.buffer.Buffer ret = io.vertx.reactivex.core.buffer.Buffer.newInstance(delegate.getBuffer(name));
 return ret;
}

代码示例来源：origin: io.knotx/knotx-core

private void sendResponse(final RoutingContext context, final ClientResponse clientResponse) {
 HttpServerResponse httpResponse = context.response();
 writeHeaders(context.response(), clientResponse);
 httpResponse.setStatusCode(clientResponse.getStatusCode());
 if (isOkClientResponse(clientResponse)) {
  httpResponse.end(Buffer.newInstance(clientResponse.getBody()));
 } else {
  httpResponse.end();
 }
}

代码示例来源：origin: Cognifide/knotx

private void sendResponse(final RoutingContext context, final ClientResponse clientResponse) {
 HttpServerResponse httpResponse = context.response();
 writeHeaders(context.response(), clientResponse);
 httpResponse.setStatusCode(clientResponse.getStatusCode());
 if (isOkClientResponse(clientResponse)) {
  httpResponse.end(Buffer.newInstance(clientResponse.getBody()));
 } else {
  httpResponse.end();
 }
}

代码示例来源：origin: io.knotx/knotx-core

private void sendResponse(final RoutingContext context, final ClientResponse clientResponse) {
 HttpServerResponse httpResponse = context.response();
 writeHeaders(context.response(), clientResponse);
 httpResponse.setStatusCode(clientResponse.getStatusCode());
 if (isOkClientResponse(clientResponse)) {
  httpResponse.end(Buffer.newInstance(clientResponse.getBody()));
 } else {
  httpResponse.end();
 }
}

代码示例来源：origin: io.knotx/knotx-server

private void sendResponse(final RoutingContext context, final ClientResponse clientResponse) {
 HttpServerResponse httpResponse = context.response();
 writeHeaders(context.response(), clientResponse);
 httpResponse.setStatusCode(clientResponse.getStatusCode());
 if (isOkClientResponse(clientResponse)) {
  httpResponse.end(Buffer.newInstance(clientResponse.getBody()));
 } else {
  httpResponse.end();
 }
}

代码示例来源：origin: io.knotx/knotx-server

private void sendResponse(final RoutingContext context, final ClientResponse clientResponse) {
 HttpServerResponse httpResponse = context.response();
 writeHeaders(context.response(), clientResponse);
 httpResponse.setStatusCode(clientResponse.getStatusCode());
 if (isOkClientResponse(clientResponse)) {
  httpResponse.end(Buffer.newInstance(clientResponse.getBody()));
 } else {
  httpResponse.end();
 }
}

代码示例来源：origin: Cognifide/knotx

private void sendResponse(final RoutingContext context, final ClientResponse clientResponse) {
 HttpServerResponse httpResponse = context.response();
 writeHeaders(context.response(), clientResponse);
 httpResponse.setStatusCode(clientResponse.getStatusCode());
 if (isOkClientResponse(clientResponse)) {
  httpResponse.end(Buffer.newInstance(clientResponse.getBody()));
 } else {
  httpResponse.end();
 }
}

代码示例来源：origin: Cognifide/knotx

private void endResponse(ClientResponse repoResponse, RoutingContext context) {
 writeHeaders(context.response(), repoResponse.getHeaders());
 context.response().setStatusCode(repoResponse.getStatusCode());
 if (repoResponse.getBody() != null) {
  context.response().end(Buffer.newInstance(repoResponse.getBody()));
 } else {
  context.response().end();
 }
}

代码示例来源：origin: io.knotx/knotx-core

private void endResponse(ClientResponse repoResponse, RoutingContext context) {
 writeHeaders(context.response(), repoResponse.getHeaders());
 context.response().setStatusCode(repoResponse.getStatusCode());
 if (repoResponse.getBody() != null) {
  context.response().end(Buffer.newInstance(repoResponse.getBody()));
 } else {
  context.response().end();
 }
}

代码示例来源：origin: io.knotx/knotx-server

private void endResponse(ClientResponse repoResponse, RoutingContext context) {
 writeHeaders(context.response(), repoResponse.getHeaders());
 context.response().setStatusCode(repoResponse.getStatusCode());
 if (repoResponse.getBody() != null) {
  context.response().end(Buffer.newInstance(repoResponse.getBody()));
 } else {
  context.response().end();
 }
}

代码示例来源：origin: tsegismont/vertx-musicstore

@Override
public void handle(RoutingContext rc) {
 Long albumId = PathUtil.parseLongParam(rc.pathParam("albumId"));
 if (albumId == null) {
  rc.next();
  return;
 }
 // Currently there's an issue with rx.Buffer as value type, so workaround with core Buffer
 LocalMap<Long, io.vertx.core.buffer.Buffer> covers = rc.vertx().sharedData().getLocalMap("covers");
 io.vertx.core.buffer.Buffer cached = covers.get(albumId);
 if (cached != null) {
  rc.response().end(Buffer.newInstance(cached));
  return;
 }
 download(albumId)
  .doOnSuccess(buffer -> covers.put(albumId, buffer.getDelegate()))
  .subscribe(rc.response()::end, rc::fail, () -> rc.fail(404));
}