Category "reactor"

How to find first match in Flux and stop processing in Reactor

Can't figure out how to stop processing Flux on first match. This what I have right now: findAll(): Flux<Object> findStorageId(Relation r): Mono<Long&g

How to catch exceptions thrown from reactor?

I want to catch exceptions thrown from a flux, my code is like this: try { Flux.just("key1", "key2", "key3") .doOnNext(S

What is the best way to do async side effect in Reactor?

Let's assume I have a main chain with some processing and I want to call billing service on each item processed and then return the results of the processing fu

Scrapy - ReactorAlreadyInstalledError when using TwistedScheduler

I have the following Python code to start APScheduler/TwistedScheduler cronjob to start the spider. Using one spider was not a problem and worked great. However

How to convert Mono object without blocking?

Suppose I have this method: public static Mono<String> getData2() { return Mono.just("7"); } I want to call this method, get back the string, convert

Restarting inifinite Flux on error with pubSubReactiveFactory

I'm developing an application which uses reactor libraries to connect with Google pubsub. So I have a Flux of messages. I want it to always consume from the que