Top "Reactive-programming" 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

How to manually send next signal to a observable in RxSwift?

I create an observable using the following code: let disposeBag = DisposeBag() let myJust = { (element: String) -> Observable<String&…

ios swift reactive-programming rx-swift

React-Native: How to make image array

I have a screen on which I want to have 4 images. How can I make it so that when I …

react-native reactive-programming react-native-ios react-android react-native-image

unable to start spring boot web application

I am trying to create a basic application that would use Spring Boot and reactive programming (and without web.xml) …

java gradle spring-boot reactive-programming gretty

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

Chaining dependent signals in ReactiveCocoa

In ReactiveCocoa, if we chaining several dependent signals, we must use subscribeNext: for the next signal in the chain to …

ios objective-c reactive-programming reactive-cocoa

How can I make this rxjava zip to run in parallel?

I have a sleep method for simulating a long running process. private void sleep() { try { Thread.sleep(2000); } catch (InterruptedException e) { …

java android rx-java reactive-programming rx-android

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

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