Top "Reactive-streams" questions

How to handle errors in Spring reactor Mono or Flux?

I have below code retuning Mono<Foo>: try { return userRepository.findById(id) // step 1 .flatMap(user -> barRepository.…

spring project-reactor reactive-streams

How to correctly read Flux<DataBuffer> and convert it to a single inputStream

I'm using WebClient and custom BodyExtractorclass for my spring-boot application WebClient webLCient = WebClient.create(); webClient.get() .uri(url, params) .accept(…

java spring project-reactor spring-webflux reactive-streams

Mono vs Flux in Reactive Stream

As per the documentation: Flux is a stream which can emit 0..N elements: Flux<String> fl = Flux.just("…

reactive-programming project-reactor reactive-streams

Flutter BLoC pattern - How can I navigate to another screen after a stream event?

My question is about navigation used with the BLoC pattern. In my LoginScreen widget I have a button that adds …

dart flutter dart-async reactive-streams

RxJava 2.0 - How to convert Observable to Publisher

How to convert Observable to Publisher in RxJava version 2? In the first version we have the https://github.com/ReactiveX/…

java reactive-programming reactivex reactive-streams rx-java2

compose() vs. transform() vs. as() vs. map() in Flux and Mono

Recently, I decided to try spring 5 with projectreactor.io (io.projectreactor:3.1.1). Does anyone know what the best case of using …

reactive-programming project-reactor reactive-streams

publishOn vs subscribeOn in Project Reactor 3

I am using publishOn vs subscribeOn both on the same flux as follows: System.out.println("*********Calling Concurrency************"); List<…

reactive-programming publish-subscribe project-reactor publisher reactive-streams

Reactor Flux<MyObject> to Mono<List<MyObject>>

How can I convert Flux<MyObject> directly to Mono<List<MyObject>> ? I am looking …

kotlin project-reactor reactive-streams

Combining result from Flux to result from Mono

I started using Project reactor and one place where I'm struggling little is how do I combine things coming from …

spring-webflux project-reactor reactive-streams

How to return Mono<B> from Mono<A> on error?

Let's say i have the following chain: public Mono<B> someMethod( Object arg ) { Mono<A> monoA = …

java reactive-programming project-reactor reactive-streams