Top "Project-reactor" questions

How do I use Reactor's StepVerifier to verify a Mono is empty?

I am using StepVerifier to test values: @Test public void testStuff() { Thing thing = new Thing(); Mono<Thing> result = …

java unit-testing reactive-programming project-reactor

Benefits of having HTTP endpoints return Flux/Mono instances instead of DTOs

I've watched Spring Tips: Functional Reactive Endpoints with Spring Framework 5.0 and read a little about spring reactor but I can't …

spring netty reactive-programming spring-webflux project-reactor

What's the difference between "text/event-stream" and "application/stream+json"

@GetMapping(path = "/cars", produces = "text/event-stream") public Flux<Car> getCarStream() { System.out.println("application/stream+json"); return this.…

java spring-webflux project-reactor

How to parse a Spring 5 WebClient response in a non-blocking way?

I'm using Spring WebFlux WebClient to retrieve data from an external API, like this: public WeatherWebClient() { this.weatherWebClient = WebClient.create("…

functional-programming jackson reactive-programming spring-webflux project-reactor

How do we convert a Mono<List<Type>> to a Flux<Type>

Using spring 5, with reactor we have the following need. Mono<TheResponseObject> getItemById(String id){ return webClient.uri('/…

spring project-reactor reactive

Spring WebClient: How to stream large byte[] to file?

It seems like it the Spring RestTemplate isn't able to stream a response directly to file without buffering it all …

java spring spring-webflux project-reactor spring-webclient

Project Reactor timeout handling

I have three questions related to Project Reactor and I will ask them below. Start with the code that I …

java project-reactor

How to create a Spring Reactor Flux from a ActiveMQ queue?

I am experimenting with the Spring Reactor 3 components and Spring Integration to create a reactive stream (Flux) from a JMS …

java spring spring-integration reactive-programming project-reactor

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

Can I use SpringMvc and webflux together?

I would like to use 2 approaches(reactive and standard) in one project. I tried to migrate one REST API endpoint …

java spring-boot reactive-programming spring-webflux project-reactor