reactor.core.publisher.Mono.flatMap()方法的使用及代码示例

x33g5p2x  于2022-01-24 转载在 其他  
字(10.4k)|赞(0)|评价(0)|浏览(816)

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

Mono.flatMap介绍

[英]Transform the item emitted by this Mono asynchronously, returning the value emitted by another Mono (possibly changing the value type).
[中]异步转换此Mono发出的项，返回另一个Mono发出的值（可能更改值类型）。

代码示例

代码示例来源：origin: spring-projects/spring-framework

/**
 * Adapt the given request processor function to a filter function that only
 * operates on the {@code ClientRequest}.
 * @param processor the request processor
 * @return the resulting filter adapter
 */
static ExchangeFilterFunction ofRequestProcessor(Function<ClientRequest, Mono<ClientRequest>> processor) {
  Assert.notNull(processor, "ClientRequest Function must not be null");
  return (request, next) -> processor.apply(request).flatMap(next::exchange);
}

代码示例来源：origin: spring-projects/spring-framework

/**
 * Adapt the given request processor function to a filter function that only operates
 * on the {@code ServerRequest}.
 * @param requestProcessor the request processor
 * @return the filter adaptation of the request processor
 */
static HandlerFilterFunction<?, ?> ofRequestProcessor(
    Function<ServerRequest, Mono<ServerRequest>> requestProcessor) {
  Assert.notNull(requestProcessor, "Function must not be null");
  return (request, next) -> requestProcessor.apply(request).flatMap(next::handle);
}

代码示例来源：origin: spring-projects/spring-framework

/**
 * Adapt the given response processor function to a filter function that only operates
 * on the {@code ServerResponse}.
 * @param responseProcessor the response processor
 * @return the filter adaptation of the request processor
 */
static <T extends ServerResponse, R extends ServerResponse> HandlerFilterFunction<T, R> ofResponseProcessor(
    Function<T, Mono<R>> responseProcessor) {
  Assert.notNull(responseProcessor, "Function must not be null");
  return (request, next) -> next.handle(request).flatMap(responseProcessor);
}

代码示例来源：origin: spring-projects/spring-framework

@Override
public <T> Mono<T> bodyToMono(Class<T> bodyType) {
  return this.responseMono.flatMap(response -> handleBody(response,
      response.bodyToMono(bodyType), mono -> mono.flatMap(Mono::error)));
}

代码示例来源：origin: spring-projects/spring-framework

@Override
public <T> Mono<T> bodyToMono(ParameterizedTypeReference<T> bodyType) {
  return this.responseMono.flatMap(response ->
      handleBody(response, response.bodyToMono(bodyType), mono -> mono.flatMap(Mono::error)));
}

代码示例来源：origin: spring-projects/spring-framework

/**
 * Adapt the given response processor function to a filter function that
 * only operates on the {@code ClientResponse}.
 * @param processor the response processor
 * @return the resulting filter adapter
 */
static ExchangeFilterFunction ofResponseProcessor(Function<ClientResponse, Mono<ClientResponse>> processor) {
  Assert.notNull(processor, "ClientResponse Function must not be null");
  return (request, next) -> next.exchange(request).flatMap(processor);
}

代码示例来源：origin: spring-projects/spring-framework

private Mono<Void> invokeModelAttributeMethods(BindingContext bindingContext,
    List<InvocableHandlerMethod> modelMethods, ServerWebExchange exchange) {
  List<Mono<HandlerResult>> resultList = new ArrayList<>();
  modelMethods.forEach(invocable -> resultList.add(invocable.invoke(exchange, bindingContext)));
  return Mono
      .zip(resultList, objectArray ->
          Arrays.stream(objectArray)
              .map(object -> handleResult(((HandlerResult) object), bindingContext))
              .collect(Collectors.toList()))
      .flatMap(Mono::when);
}

代码示例来源：origin: spring-projects/spring-framework

@Override
public Mono<Void> write(Publisher<? extends Resource> inputStream, ResolvableType elementType,
    @Nullable MediaType mediaType, ReactiveHttpOutputMessage message, Map<String, Object> hints) {
  return Mono.from(inputStream).flatMap(resource ->
      writeResource(resource, elementType, mediaType, message, hints));
}

代码示例来源：origin: spring-projects/spring-framework

@Override
public Mono<Void> write(Publisher<? extends MultiValueMap<String, ?>> inputStream,
    ResolvableType elementType, @Nullable MediaType mediaType, ReactiveHttpOutputMessage outputMessage,
    Map<String, Object> hints) {
  return Mono.from(inputStream).flatMap(map -> {
    if (this.formWriter == null || isMultipart(map, mediaType)) {
      return writeMultipart(map, outputMessage, hints);
    }
    else {
      @SuppressWarnings("unchecked")
      MultiValueMap<String, String> formData = (MultiValueMap<String, String>) map;
      return this.formWriter.write(Mono.just(formData), elementType, mediaType, outputMessage, hints);
    }
  });
}

代码示例来源：origin: spring-projects/spring-framework

protected Mono<Resource> getResource(ServerWebExchange exchange) {
  String name = HandlerMapping.PATH_WITHIN_HANDLER_MAPPING_ATTRIBUTE;
  PathContainer pathWithinHandler = exchange.getRequiredAttribute(name);
  String path = processPath(pathWithinHandler.value());
  if (!StringUtils.hasText(path) || isInvalidPath(path)) {
    return Mono.empty();
  }
  if (isInvalidEncodedPath(path)) {
    return Mono.empty();
  }
  Assert.state(this.resolverChain != null, "ResourceResolverChain not initialized");
  Assert.state(this.transformerChain != null, "ResourceTransformerChain not initialized");
  return this.resolverChain.resolveResource(exchange, path, getLocations())
      .flatMap(resource -> this.transformerChain.transform(exchange, resource));
}

代码示例来源：origin: spring-projects/spring-framework

@Override
public Mono<Void> doFilter(ServerWebExchange exchange, WebFilterChain chain) {
  return doAsyncWork().flatMap(asyncResult -> {
    logger.debug("Async result: " + asyncResult);
    return chain.filter(exchange);
  });
}

代码示例来源：origin: spring-projects/spring-framework

@Override
public Mono<Void> handle(ServerWebExchange exchange) {
  if (this.handlerMappings == null) {
    return createNotFoundError();
  }
  return Flux.fromIterable(this.handlerMappings)
      .concatMap(mapping -> mapping.getHandler(exchange))
      .next()
      .switchIfEmpty(createNotFoundError())
      .flatMap(handler -> invokeHandler(exchange, handler))
      .flatMap(result -> handleResult(exchange, result));
}

代码示例来源：origin: spring-projects/spring-framework

private Mono<Void> handleResult(ServerWebExchange exchange, HandlerResult result) {
  return getResultHandler(result).handleResult(exchange, result)
      .onErrorResume(ex -> result.applyExceptionHandler(ex).flatMap(exceptionResult ->
          getResultHandler(exceptionResult).handleResult(exchange, exceptionResult)));
}

代码示例来源：origin: spring-projects/spring-framework

@Bean
public RouterFunction<?> handler() {
  return RouterFunctions.route()
      .GET("/sessionClassName", request ->
          request.session().flatMap(session -> {
            String className = session.getClass().getSimpleName();
            return ServerResponse.ok().syncBody(className);
          }))
      .build();
}

代码示例来源：origin: spring-projects/spring-framework

@Test
public void defaultContentType() {
  Mono<RenderingResponse> result = RenderingResponse.create("view").build();
  MockServerWebExchange exchange = MockServerWebExchange.from(MockServerHttpRequest.get("http://localhost"));
  TestView view = new TestView();
  ViewResolver viewResolver = mock(ViewResolver.class);
  when(viewResolver.resolveViewName(any(), any())).thenReturn(Mono.just(view));
  List<ViewResolver> viewResolvers = new ArrayList<>();
  viewResolvers.add(viewResolver);
  ServerResponse.Context context = mock(ServerResponse.Context.class);
  when(context.viewResolvers()).thenReturn(viewResolvers);
  StepVerifier.create(result.flatMap(response -> response.writeTo(exchange, context)))
      .verifyComplete();
  assertEquals(ViewResolverSupport.DEFAULT_CONTENT_TYPE, exchange.getResponse().getHeaders().getContentType());
}

代码示例来源：origin: spring-projects/spring-framework

public Mono<ServerResponse> parts(ServerRequest request) {
    return request.body(BodyExtractors.toParts()).collectList()
        .flatMap(parts -> {
          try {
            assertEquals(2, parts.size());
            assertEquals("foo.txt", ((FilePart) parts.get(0)).filename());
            assertEquals("bar", ((FormFieldPart) parts.get(1)).value());
          }
          catch(Exception e) {
            return Mono.error(e);
          }
          return ServerResponse.ok().build();
        });
  }
}

代码示例来源：origin: spring-projects/spring-framework

@Test
public void buildVoidPublisher() {
  Mono<Void> mono = Mono.empty();
  Mono<ServerResponse> result = ServerResponse.ok().build(mono);
  MockServerHttpRequest request = MockServerHttpRequest.get("http://example.com").build();
  MockServerWebExchange exchange = MockServerWebExchange.from(request);
  result.flatMap(res -> res.writeTo(exchange, EMPTY_CONTEXT)).block();
  MockServerHttpResponse response = exchange.getResponse();
  StepVerifier.create(response.getBody()).expectComplete().verify();
}

代码示例来源：origin: spring-projects/spring-framework

@Test
public void value() {
  Mono<Msg> result = this.webClient.get()
      .uri("/message")
      .exchange()
      .doOnNext(response -> {
        Assert.assertFalse(response.headers().contentType().get().getParameters().containsKey("delimited"));
        Assert.assertEquals("sample.proto", response.headers().header("X-Protobuf-Schema").get(0));
        Assert.assertEquals("Msg", response.headers().header("X-Protobuf-Message").get(0));
      })
      .flatMap(response -> response.bodyToMono(Msg.class));
  StepVerifier.create(result)
      .expectNext(TEST_MSG)
      .verifyComplete();
}

代码示例来源：origin: spring-projects/spring-framework

@Test
public void shouldReceiveEmptyResponse() {
  prepareResponse(response -> response.setHeader("Content-Length", "0").setBody(""));
  Mono<ResponseEntity<Void>> result = this.webClient.get()
      .uri("/noContent")
      .exchange()
      .flatMap(response -> response.toEntity(Void.class));
  StepVerifier.create(result).assertNext(r -> {
    assertTrue(r.getStatusCode().is2xxSuccessful());
  }).verifyComplete();
}

代码示例来源：origin: spring-projects/spring-framework

@Test
public void build() {
  ResponseCookie cookie = ResponseCookie.from("name", "value").build();
  Mono<ServerResponse>
      result = ServerResponse.status(HttpStatus.CREATED)
      .header("MyKey", "MyValue")
      .cookie(cookie).build();
  MockServerHttpRequest request = MockServerHttpRequest.get("http://example.com").build();
  MockServerWebExchange exchange = MockServerWebExchange.from(request);
  result.flatMap(res -> res.writeTo(exchange, EMPTY_CONTEXT)).block();
  MockServerHttpResponse response = exchange.getResponse();
  assertEquals(HttpStatus.CREATED, response.getStatusCode());
  assertEquals("MyValue", response.getHeaders().getFirst("MyKey"));
  assertEquals("value", response.getCookies().getFirst("name").getValue());
  StepVerifier.create(response.getBody()).expectComplete().verify();
}

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

Mono

相关文章

    查看更多

    热门标签

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

    最新文章

    更多

    Mono类方法

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