fromCallable and defer have different implementation. I heard some say that defer helps with recursion but i can't produce any code that shows the difference between them. i tried with infinite nu...

In Spring Data, we have PagingAndSortingRepository which inherits from CrudRepository. In reactive Spring Data, we only have ReactiveSortingRepository which inherits from ReactiveCrudRepository. H...

I’m having an issue with Spring 5 reactive WebClient, when I request an endpoint that returns a correctly formated json response with content type "text/plain;charset=UTF-8". The exception is org....

I am still trying to understand the difference between the reactor map() and flatMap() method. First I took a look at the API, but it isn't really helpful, it confused me even more. Then I googled ...

Client applications sends request to server, that could potentially take long to complete. Once request is finished or failed, client should wait some period of time (i.e. 10 seconds) and then agai...

I have a Webflux based microservice that has a simple reactive repository: public interface NotificationRepository extends ReactiveMongoRepository<Notification, ObjectId> { } Now I would l...

I read the Shiny documentation about reactive programming a few times now, but I can't properly understand the difference between observeEvent and eventReactive. The documentation says: Use observ...

I am using StepVerifier to test values: @Test public void testStuff() { Thing thing = new Thing(); Mono<Thing> result = Mono.just(thing); StepVerifier.create(result).consumeNextWith(r -&g...

I have an IObservable that generates items that are disposable, and it will generate a potentially infinite number of them over its lifetime. Because of this, I want to dispose of the last item eac...

Given the following data structure Data and Flux<Data> what is idiomatic way to achieve grouping into series of lists based on some property: import org.reactivestreams.Publisher; import rea...

I've been learning a bit about Spring 5 WebFlux, reactive programming and websockets. I've watched Josh Long's Spring Tips: Reactive WebSockets with Spring Framework 5. The code that sends data fro...

Let's say I have an array of ids: [9, 8, 7, 6]. I do some processing and one element causes to throw an exception. I want to handle this situation on my own way (let's say log it) and let the other...

I want to have a Mono that calls another async method that returns an Optional type to: have a value if the Optional is not empty, is MonoEmpty if the Optional value is empty. Here's what I do ...

In Flux map function is also executed for each item in the flux. For doOnNext function is also executed for every item (emitted) in the flux. What is the difference from the user's perspective? Why...

I believe it is a standard to log request and response in order to track down any issues reported by users and also to integrate it with tools like Splunk. I've found 2 approaches so far, but none ...

I have a method that returns an Observable<ArrayList<Long>>, which are ids of some Items. I'd like to go through this list and download every Item using another method that returns Obse...

Update: check out the example at the bottom I need to message between classes. The publisher will loop indefinitely, call some method to get data, and then pass the result of that call into OnNext....

Why do we need to use RxAndroid with RxJava? What is the functional difference between them and actual use of RxAndroid and RxJava? I can't find proper answer for this.

Is there any possibility to update an input without reactives getting triggered? Below I put a minimal example. The aim is to update the slider without the value in the main panel changing. When t...

Right now I'm trying to port the logic of an existing reactive Angular application (RxJS-based) to Flutter. I'm facing a lot of problems with the dart streams API, which seems to behave quite diffe...

Is this the correct way to handle reactively? I see 2 threads one reactive nio which is until and including flatMap(fareRepo::save). The other thread is computations thread which starts from sendin...

I am trying to filter the list on the basis of it's property. For example, Sensors class has a property isActive and I want to get all the objects with isActive as true but I am unable to do it. I ...

I have only started learning combine, so it's still a little fuzzy to me. I would like to create a custom Publisher, that would use CLLocationManager to expose current user location. I would like i...

How to test a stream in dart? I have this code: test('words are reading sequentially correct', () { WordTrackerInterface wordTracker = WordTracker.byContent('0 1 2'); wordTracker.setWordsCountPe...

I’m starting to learn reactive programming in Java. The whole reactive paradigm is new to me. In my learning process, i have come across few terms/libraries such as Spring WebFlux, projectreactor...