Tag: PROJECT-REACTOR
Estoy implementando un listener de SQS reactivo y me enfrento a un problema con las suscripciones anidadas. Así es como se ve mi listener: @PostConstruct public void listener() { Mono<ReceiveMessageResponse> receiveMessageResponseMono = Mono.fromFuture( () -> sqsAsyncClient.receiveMessage( ReceiveMessageRequest.builder() .queueUrl(queueUrl) .maxNumberOfMessages(MAX<em>NUMBER</em>OF<em>MESSAGES) .waitTimeSeconds(WAIT</em>TIME<em>IN</em>SECONDS) .build())); } receiveMessageResponseMono .repeat() .retry() .map(ReceiveMessageResponse::messages) .map(Flux::fromIterable) .flatMap(messageFlux -> messageFlux) . . . Read more
Tengo dos métodos dependientes entre sí. Flux<DataBuffer> flux = service1.get(); Mono<String> s = service2.store(flux); service1.get() devuelve Flux<DataBuffer> o Flux.error en caso de una operación de obtención no exitosa. service2.store(Flux<DataBuffer> flux) devuelve Mono<String> o Mono.error en caso de una operación de almacenamiento no exitosa. Service2 es un cliente reactivo Feign que . . . Read more
Soy un principiante completo en el mundo reactivo, así que mientras revisaba algunos ejemplos en Reactive Repositories, encontré lo siguiente: reactiverepository.save(employee).subscribe() // me suscribo para que el publicador emita los datos reactiverepository.findAll() // ¿sin subscribe()? Sé que para que un publicador (Flux en el caso anterior) emita los datos, necesitamos . . . Read more
Actualmente, tengo una pregunta, algo así: WebClient.call(…) .flatMap(user -> webclient.call(“host1”, user.getId/*obj request*/);})//se asume que esto devuelve X.class (*) .flatMap(x -> webclient.call(“host2”, user.getName/*obj request*/))// “x” no se usa aquí, quiero reutilizar el objeto “user” pero hay un error de compilación, se asume que esto devuelve Y.class .map(x -> webclient.call(…))// “x” se . . . Read more
En este momento estoy experimentando un problema realmente extraño y frustrante. Tengo un código que está siendo probado y se ejecuta a través de una cadena de llamadas reactivas que contienen una serie de operaciones de filtrado. A medida que la prueba corre a través del código y se devuelve . . . Read more