At some point in our code using rxjava we have public Maybe<Event> verifyFoo(Event event){ return Maybe.just(event) .flatMap(this::foo) .doOnComplete(() -> ...

I'm experiencing a confusing timing issue with RxJava's Maybe operators in a high-throughput service (40 TPS) with concurrent execution. I have two classes that log execution times, but they're ...

Given: an Observable that emits the user input; 3 states: Success, Error, Idle (shows nothing, may be treated as some progress). I want the following behavior: as soon as the user types, check if ...

In RxJava, is subscribeOn(mainThread).subscribe() guaranteed to run synchronously in mainThread? Or is it possible that another piece of work already scheduled to run on the main thread may run first? ...

I am trying to implement background polling in an RxJava-based Android application where: A repository periodically fetches data from an API every 10 seconds and emits updates via a BehaviorSubject. ...

I am attempting to stream a large HTTP request between my Vert.x services. For this purpose, I am using io.vertx.reactivex.ext.web.client.WebClient, which takes a Flowable as input for the ...

Let's say I have two observables Observable<A> with values like (1, Ametadata), (2, Ametadata) 1, 2 ... are ids and Ametadata is additional attributes of A Observable<B> with values like (...

Working on updating my app from RxJava2 to RxJava3. I know there are some updates to how groupBy works from reading the documentation, but I'm having trouble understanding why I'm seeing this ...

I have rxjava3 Flowable having Item objects and want to run async operation in batches only for elements matching a condition. Then I want to allow downstream operators to iterate over original Item ...

I am trying to understand a difference between below two snippets using rxRequest/rxSend vs request/send. They seem to behave in the same way. RecordParser parser = RecordParser.newDelimited("\n&...

I need to handle different types of events in a strict one by one manner, but in a background thread. According to the documentation, the next code, Schedulers.from(executor, false, true);, should ...

I have an Observable[T] which emits continuously and I want an Observable[List[T]] which emits the last elements in a specified duration for each element the source emits. Example Observable. range(0, ...

Reactive Streams is built around back pressure what is great and I would like to better understand how to use RxJava3 API. The approach to drop overflow data for GUI events is perfectly fine but if I ...

I have to call an API which returns an object, and inside this object, there is a list. For each item in this list, I have to retrieve item details. To retrieve details, I have to make async API calls ...

I am using RxJava in my app. Upon making changes to the version code > clearing cache > clearing data > uninstalling > reinstalling the app. The app goes straight to the HomeFragment after ...