Top "Reactive-programming" questions

Reactive Programming is a programming paradigm oriented around data flows and the propagation of change.

How to cancel an ongoing Spring Flux?

I'm using a spring flux to send parallel requests to a service, this is very simplified version of it: Flux.…

spring reactive-programming spring-webflux project-reactor
How do I sum the values in a Reactor Flux stream?

Suppose I have a repository with a findAll() method that returns an Iterable of State, where State is a class …

java reactive-programming project-reactor
Reactive WebClient not emitting a response

I have a question about Spring Reactive WebClient... Few days ago I decided to play with the new reactive stuff …

spring reactive-programming project-reactor spring-webflux
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
Comparing core.async and Functional Reactive Programming (+Rx)

I seem to be a little bit confused when comparing Clojure's core.async to the so called Reactive Extensions (Rx) …

asynchronous clojure reactive-programming frp core.async
Spring data mongodb @DBRef list

I am trying to have a list in a model using @DBRef but I can't get it to work. This …

spring mongodb reactive-programming spring-webflux dbref
What happened to Scala.React?

I read the paper cowritten by Odersky, "Deprecating the Observer Pattern with Scala.React" The github looks abandoned: https://github.…

scala observer-pattern reactive-programming
Creating Observable without using Observable.create

I am using RxJava in my Android app and I want to load data from the database. In this way, …

android reactive-programming rx-java
What is LINQ to events a.k.a RX Framework?

What is LINQ to events a.k.a RX Framework aka the Reactive Extensions in .NET 4.0 (but also available as …

linq events system.reactive reactive-programming
vert.x: How do you correctly send a post request?

I have vert.x app-server with simplest authorization, which has some route like this: router.post("/user/sign").handler(this::…

java unit-testing post reactive-programming vert.x