io.vertx.reactivex.core.buffer.Buffer.getDelegate()方法的使用及代码示例

x33g5p2x  于2022-01-16 转载在 其他  
字(9.6k)|赞(0)|评价(0)|浏览(108)

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

Buffer.getDelegate介绍

暂无

代码示例

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

/**
 * Add a buffer value at the end of the tuple.
 * @param value the value
 * @return a reference to this, so the API can be used fluently
 */
public io.reactiverse.reactivex.pgclient.Tuple addBuffer(io.vertx.reactivex.core.buffer.Buffer value) { 
 delegate.addBuffer(value.getDelegate());
 return this;
}

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

/**
 * Add a buffer value at the end of the tuple.
 * @param value the value
 * @return a reference to this, so the API can be used fluently
 */
public io.reactiverse.reactivex.pgclient.Tuple addBuffer(io.vertx.reactivex.core.buffer.Buffer value) { 
 delegate.addBuffer(value.getDelegate());
 return this;
}

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

public com.julienviet.reactivex.childprocess.StreamOutput write(io.vertx.reactivex.core.buffer.Buffer buffer) { 
 delegate.write(buffer.getDelegate());
 return this;
}

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

public void end(io.vertx.reactivex.core.buffer.Buffer t) { 
 delegate.end(t.getDelegate());
}

代码示例来源：origin: io.knotx/knotx-repository-connector-filesystem

@Override
public void process(ClientRequest request, Handler<AsyncResult<ClientResponse>> result) {
 final String localFilePath = catalogue + StringUtils.stripStart(request.getPath(), "/");
 final Optional<String> contentType = Optional
   .ofNullable(MimeMapping.getMimeTypeForFilename(localFilePath));
 LOGGER.debug("Fetching file `{}` from local repository.", localFilePath);
 fileSystem.rxReadFile(localFilePath)
   .map(buffer -> new ClientResponse().setStatusCode(HttpResponseStatus.OK.code())
     .setHeaders(headers(contentType)).setBody(buffer.getDelegate()))
   .subscribe(
     response -> result.handle(Future.succeededFuture(response)),
     error -> {
      LOGGER.error(ERROR_MESSAGE, error);
      result.handle(Future.succeededFuture(processError(error)));
     }
   );
}

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

@Override
public void process(ClientRequest request, Handler<AsyncResult<ClientResponse>> result) {
 final String localFilePath =
   config.getCatalogue() + StringUtils.stripStart(request.getPath(), "/");
 final Optional<String> contentType = Optional
   .ofNullable(MimeMapping.getMimeTypeForFilename(localFilePath));
 LOGGER.debug("Fetching file `{}` from local repository.", localFilePath);
 fileSystem.rxReadFile(localFilePath)
   .map(buffer -> new ClientResponse().setStatusCode(HttpResponseStatus.OK.code())
     .setHeaders(headers(contentType)).setBody(buffer.getDelegate()))
   .subscribe(
     response -> result.handle(Future.succeededFuture(response)),
     error -> {
      LOGGER.error(ERROR_MESSAGE, error);
      result.handle(Future.succeededFuture(processError(error)));
     }
   );
}

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

@Override
public void process(ClientRequest request, Handler<AsyncResult<ClientResponse>> result) {
 final String localFilePath =
   config.getCatalogue() + StringUtils.stripStart(request.getPath(), "/");
 final Optional<String> contentType = Optional
   .ofNullable(MimeMapping.getMimeTypeForFilename(localFilePath));
 LOGGER.debug("Fetching file `{}` from local repository.", localFilePath);
 fileSystem.rxReadFile(localFilePath)
   .map(buffer -> new ClientResponse().setStatusCode(HttpResponseStatus.OK.code())
     .setHeaders(headers(contentType)).setBody(buffer.getDelegate()))
   .subscribe(
     response -> result.handle(Future.succeededFuture(response)),
     error -> {
      LOGGER.error(ERROR_MESSAGE, error);
      result.handle(Future.succeededFuture(processError(error)));
     }
   );
}

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

@Test
 public void handleRepositoryResponse_whenResponseIsError_expectErrorResponse() {
  when(clientResponse.getStatusCode()).thenReturn(400);
  when(clientResponse.getHeaders()).thenReturn(MultiMap.caseInsensitiveMultiMap());
  when(clientResponse.getBody()).thenReturn(Buffer.buffer().getDelegate());
  when(routingContext.response()).thenReturn(httpServerResponse);

  tested.handleRepositoryResponse(clientResponse, routingContext, repositoryEntry, knotContext);

  verify(routingContext, times(0)).next();
  verify(httpServerResponse, times(1)).setStatusCode(400);
  verify(httpServerResponse, times(1)).end(any(Buffer.class));
 }
}

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

@Test
public void handleRepositoryResponse_whenResponseIsSuccessAndShouldNotBeProcessed_expectResponse() {
 when(clientResponse.getStatusCode()).thenReturn(200);
 when(repositoryEntry.isDoProcessing()).thenReturn(false);
 when(clientResponse.getHeaders()).thenReturn(MultiMap.caseInsensitiveMultiMap());
 when(clientResponse.getBody()).thenReturn(Buffer.buffer().getDelegate());
 when(routingContext.response()).thenReturn(httpServerResponse);
 tested.handleRepositoryResponse(clientResponse, routingContext, repositoryEntry, knotContext);
 verify(routingContext, times(0)).next();
 verify(httpServerResponse, times(1)).setStatusCode(200);
 verify(httpServerResponse, times(1)).end(any(Buffer.class));
}

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

private Single<ClientResponse> wrapResponse(HttpResponse<Buffer> response) {
 return toBody(response)
   .doOnSuccess(this::traceServiceCall)
   .map(buffer -> new ClientResponse()
     .setBody(buffer.getDelegate())
     .setHeaders(response.headers())
     .setStatusCode(response.statusCode())
   );
}

代码示例来源：origin: io.knotx/knotx-databridge-adapter-http

private Single<ClientResponse> wrapResponse(HttpResponse<Buffer> response) {
 return toBody(response)
   .doOnSuccess(this::traceServiceCall)
   .map(buffer -> new ClientResponse()
     .setBody(buffer.getDelegate())
     .setHeaders(response.headers())
     .setStatusCode(response.statusCode())
   );
}

代码示例来源：origin: io.knotx.acme/acme-forms-adapter-http

private Single<ClientResponse> wrapResponse(HttpResponse<Buffer> response) {
 return toBody(response)
   .doOnSuccess(this::traceServiceCall)
   .map(buffer -> new ClientResponse()
     .setBody(buffer.getDelegate())
     .setHeaders(response.headers())
     .setStatusCode(response.statusCode())
   );
}

代码示例来源：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));
}

代码示例来源：origin: com.cv4j.netdiscovery/netdiscovery-core

buffer.getDelegate().appendBytes(request.getHttpRequestBody().getBody());
  httpResponseSingle = stringHttpRequest.rxSendBuffer(buffer);
} else {

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

private ClientResponse toResponse(Buffer buffer, final HttpClientResponse httpResponse, final RequestOptions httpRequestData) {
 final int statusCode = httpResponse.statusCode();
 if (HttpStatusClass.SUCCESS.contains(statusCode)) {
  LOGGER.debug("Repository 2xx response: {}, Headers[{}]", statusCode,
    DataObjectsUtil.toString(httpResponse.headers()));
 } else if (HttpStatusClass.REDIRECTION.contains(statusCode)) { // redirect
  LOGGER.info("Repository 3xx response: {}, Headers[{}]", statusCode,
    DataObjectsUtil.toString(httpResponse.headers()));
 } else if (HttpStatusClass.CLIENT_ERROR.contains(statusCode)) { // errors
  LOGGER.warn("Repository client error 4xx. Request URL: {}, response: {}, Headers[{}]",
    getUrl(httpRequestData), statusCode, DataObjectsUtil.toString(httpResponse.headers()));
 } else if (HttpStatusClass.SERVER_ERROR.contains(statusCode)) {
  LOGGER.error("Repository server error 5xx. Request URL: {},  response: {}, Headers[{}]",
    getUrl(httpRequestData), statusCode, DataObjectsUtil.toString(httpResponse.headers()));
 } else {
  LOGGER.warn("Other response: {}, Headers[{}]", statusCode,
    DataObjectsUtil.toString(httpResponse.headers()));
 }
 return new ClientResponse()
   .setStatusCode(statusCode)
   .setHeaders(httpResponse.headers())
   .setBody(buffer.getDelegate());
}

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

private ClientResponse toResponse(Buffer buffer, final HttpClientResponse httpResponse, final RequestOptions httpRequestData) {
 final int statusCode = httpResponse.statusCode();
 if (HttpStatusClass.SUCCESS.contains(statusCode)) {
  LOGGER.debug("Repository 2xx response: {}, Headers[{}]", statusCode,
    DataObjectsUtil.toString(httpResponse.headers()));
 } else if (HttpStatusClass.REDIRECTION.contains(statusCode)) { // redirect
  LOGGER.info("Repository 3xx response: {}, Headers[{}]", statusCode,
    DataObjectsUtil.toString(httpResponse.headers()));
 } else if (HttpStatusClass.CLIENT_ERROR.contains(statusCode)) { // errors
  LOGGER.warn("Repository client error 4xx. Request URL: {}, response: {}, Headers[{}]",
    getUrl(httpRequestData), statusCode, DataObjectsUtil.toString(httpResponse.headers()));
 } else if (HttpStatusClass.SERVER_ERROR.contains(statusCode)) {
  LOGGER.error("Repository server error 5xx. Request URL: {},  response: {}, Headers[{}]",
    getUrl(httpRequestData), statusCode, DataObjectsUtil.toString(httpResponse.headers()));
 } else {
  LOGGER.warn("Other response: {}, Headers[{}]", statusCode,
    DataObjectsUtil.toString(httpResponse.headers()));
 }
 return new ClientResponse()
   .setStatusCode(statusCode)
   .setHeaders(httpResponse.headers())
   .setBody(buffer.getDelegate());
}

代码示例来源：origin: FroMage/redpipe

if (buff.length() > 0)
 ByteBufInputStream in = new ByteBufInputStream(buff.getDelegate().getByteBuf());
 vertxRequest.setInputStream(in);

代码示例来源：origin: net.redpipe/redpipe-engine

if (buff.length() > 0)
 ByteBufInputStream in = new ByteBufInputStream(buff.getDelegate().getByteBuf());
 vertxRequest.setInputStream(in);

内容来源于网络，如有侵权，请联系作者删除！

Buffer

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com