Java DataBuffer类代码示例

OGeek|极客世界-中国程序员成长平台 › 门户 › 编程› Java›Java编程经验

原作者: [db:作者] 来自: [db:来源] 收藏邀请

本文整理汇总了Java中org.springframework.core.io.buffer.DataBuffer类的典型用法代码示例。如果您正苦于以下问题：Java DataBuffer类的具体用法？Java DataBuffer怎么用？Java DataBuffer使用的例子？那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。

DataBuffer类属于org.springframework.core.io.buffer包，在下文中一共展示了DataBuffer类的20个代码示例，这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞，您的评价将有助于我们的系统推荐出更棒的Java代码示例。

示例1: renderInternal

import org.springframework.core.io.buffer.DataBuffer; //导入依赖的package包/类
@Override
protected Mono<Void> renderInternal(Map<String, Object> model, MediaType contentType,
                                    ServerWebExchange exchange) {
    Resource resource = resolveResource();
    if (resource == null) {
        return Mono.error(new IllegalStateException(
                "Could not find Mustache template with URL [" + getUrl() + "]"));
    }
    DataBuffer dataBuffer = exchange.getResponse().bufferFactory().allocateBuffer();
    try (Reader reader = getReader(resource)) {
        Template template = this.compiler.compile(reader);
        Charset charset = getCharset(contentType).orElse(getDefaultCharset());
        try (Writer writer = new OutputStreamWriter(dataBuffer.asOutputStream(),
                charset)) {
            template.execute(model, writer);
            writer.flush();
        }
    }
    catch (Exception ex) {
        DataBufferUtils.release(dataBuffer);
        return Mono.error(ex);
    }
    return exchange.getResponse().writeWith(Flux.just(dataBuffer));
}

开发者ID:hantsy，项目名称:spring-reactive-sample，代码行数:25，代码来源:MustacheView.java

示例2: exchange

import org.springframework.core.io.buffer.DataBuffer; //导入依赖的package包/类
@GetMapping("/exchange")
public Mono<Void> exchange(ServerWebExchange webExchange) {
    ServerHttpResponse response = webExchange.getResponse();
    response.setStatusCode(HttpStatus.OK);
    response.getHeaders().setContentType(MediaType.TEXT_PLAIN);
    DataBuffer dataBuffer = factory.allocateBuffer().write("Using exchange!".getBytes(StandardCharsets.UTF_8));
    return response.writeWith(Mono.just(dataBuffer));
}

开发者ID:aliaksei-lithium，项目名称:spring5demo，代码行数:9，代码来源:SampleController.java

示例3: buildBody

import org.springframework.core.io.buffer.DataBuffer; //导入依赖的package包/类
private BodyInserter<?, ? super ClientHttpRequest> buildBody(Object[] args) {
    if (bodyIndex == null) {
        return BodyInserters.empty();
    }
    
    Object body = args[bodyIndex];
    if (isDataBufferPublisher(requestBodyType)) {
        return BodyInserters.fromDataBuffers((Publisher<DataBuffer>) body);
    } else if (isPublisher(requestBodyType)) {
        return BodyInserters.fromPublisher((Publisher) body, requestBodyType.getGeneric(0).getRawClass());
    } else if (isResource(requestBodyType)) {
        return BodyInserters.fromResource((Resource) body);
    } else if (isFormData(requestBodyType)) {
        return BodyInserters.fromFormData((MultiValueMap<String, String>) body);
    } else {
        return BodyInserters.fromObject(body);
    }
}

开发者ID:jbrixhe，项目名称:spring-webflux-client，代码行数:19，代码来源:RequestTemplate.java

示例4: post

import org.springframework.core.io.buffer.DataBuffer; //导入依赖的package包/类
@PostMapping
public Mono<ResponseEntity<String>> post(@PathVariable String applicationId,
		ServerHttpRequest request) {
	return configure(this.webClient.post(), applicationId, request) //
			.flatMap(spec -> spec
					.header(CONTENT_TYPE, request.getHeaders().getFirst(CONTENT_TYPE)) //
					.body(request.getBody(), DataBuffer.class) //
					.exchange() //
					.flatMap(res -> res.bodyToMono(String.class) //
							.map(b -> ResponseEntity.status(res.statusCode()).body(b)) //
							.switchIfEmpty(emptyResponse(res))));
}

开发者ID:making，项目名称:spring-boot-actuator-dashboard，代码行数:13，代码来源:ProxyController.java

示例5: readToString

import org.springframework.core.io.buffer.DataBuffer; //导入依赖的package包/类
public static String readToString(DataBuffer dataBuffer) {
    try {
        return FileCopyUtils.copyToString(new InputStreamReader(dataBuffer.asInputStream()));
    }
    catch (IOException e) {
        return e.getMessage();
    }
}

开发者ID:jbrixhe，项目名称:spring-webflux-client，代码行数:9，代码来源:DataBuffers.java

示例6: readMono

import org.springframework.core.io.buffer.DataBuffer; //导入依赖的package包/类
@Test
public void readMono(){
    HttpStatus status = HttpStatus.BAD_REQUEST;
    ClientHttpResponse httpResponse = request(status, "Exception Mono error message");
    RuntimeException exception = new HttpServerException(status);
    when(errorDecoder.decode(same(status), any(DataBuffer.class))).thenReturn(exception);

    StepVerifier.create(errorReader.readMono(httpResponse))
            .verifyError(HttpServerException.class);
    
    verify(errorDecoder).decode(same(status), any(DataBuffer.class));
    verifyNoMoreInteractions(errorDecoder);
}

开发者ID:jbrixhe，项目名称:spring-webflux-client，代码行数:14，代码来源:DecoderHttpErrorReaderTest.java

示例7: read

import org.springframework.core.io.buffer.DataBuffer; //导入依赖的package包/类
@Test
public void read(){
    HttpStatus status = HttpStatus.BAD_REQUEST;
    ClientHttpResponse httpResponse = request(status, "Exception Flux error message");
    RuntimeException exception = new HttpServerException(status);
    when(errorDecoder.decode(same(status), any(DataBuffer.class))).thenReturn(exception);
    
    StepVerifier.create(errorReader.read(httpResponse))
            .verifyError(HttpServerException.class);
    
    verify(errorDecoder).decode(same(status), any(DataBuffer.class));
    verifyNoMoreInteractions(errorDecoder);
}

开发者ID:jbrixhe，项目名称:spring-webflux-client，代码行数:14，代码来源:DecoderHttpErrorReaderTest.java

示例8: ConvertedBodyResponse

import org.springframework.core.io.buffer.DataBuffer; //导入依赖的package包/类
private ConvertedBodyResponse(ClientResponse response,
                              Function<Flux<DataBuffer>, Flux<DataBuffer>> converter,
                              MediaType contentType) {
    this.response = response;
    this.converter = converter;
    this.headers = new Headers() {
        @Override
        public OptionalLong contentLength() {
            return response.headers().contentLength();
        }

        @Override
        public Optional<MediaType> contentType() {
            return Optional.ofNullable(contentType);
        }

        @Override
        public List<String> header(String headerName) {
            if (headerName.equals(HttpHeaders.CONTENT_TYPE)) {
                return singletonList(contentType.toString());
            }
            return response.headers().header(headerName);
        }

        @Override
        public HttpHeaders asHttpHeaders() {
            HttpHeaders newHeaders = new HttpHeaders();
            newHeaders.putAll(response.headers().asHttpHeaders());
            newHeaders.replace(HttpHeaders.CONTENT_TYPE, singletonList(contentType.toString()));
            return HttpHeaders.readOnlyHttpHeaders(newHeaders);
        }
    };
}

开发者ID:codecentric，项目名称:spring-boot-admin，代码行数:34，代码来源:InstanceFilterFunctions.java

示例9: body

import org.springframework.core.io.buffer.DataBuffer; //导入依赖的package包/类
@Override
public <T> T body(BodyExtractor<T, ? super ClientHttpResponse> extractor) {
    return response.body((inputMessage, context) -> {
        ClientHttpResponse convertedMessage = new ClientHttpResponseDecorator(inputMessage) {
            @Override
            public Flux<DataBuffer> getBody() {
                return super.getBody().transform(ConvertedBodyResponse.this.converter);
            }
        };
        return extractor.extract(convertedMessage, context);
    });
}

开发者ID:codecentric，项目名称:spring-boot-admin，代码行数:13，代码来源:InstanceFilterFunctions.java

示例10: convertUsing

import org.springframework.core.io.buffer.DataBuffer; //导入依赖的package包/类
@SuppressWarnings("unchecked")
private static <S, T> Function<Flux<DataBuffer>, Flux<DataBuffer>> convertUsing(ParameterizedTypeReference<S> sourceType,
                                                                                ParameterizedTypeReference<T> targetType,
                                                                                Function<S, T> converterFn) {
    return input -> DECODER.decodeToMono(input, ResolvableType.forType(sourceType), null, null)
                           .map(body -> converterFn.apply((S) body))
                           .flatMapMany(output -> ENCODER.encode(Mono.just(output), new DefaultDataBufferFactory(),
                                   ResolvableType.forType(targetType), null, null));
}

开发者ID:codecentric，项目名称:spring-boot-admin，代码行数:10，代码来源:LegacyEndpointConverters.java