Hot questions for RxJava 2

Categories Question List
Using RxJava 2 in android room Android Retrofit2/RxJava2/Room - Simple Data Processing
Flowable not updated after inserting data inside a transaction
Room + RxJava 2 How to check for a record in a table in which a column is equal to a specific value
RxJava, Room: Best way to update all the rows of Db using rxjava chain calls
Room doesn't execute AddNewCallback
Using RxJava 2 in arraylist How to filter Arraylist with RxJava2
How to group an ArrayList using RxJava2 based on some attribute?
Use rxjava2 to loop through an arraylist
Refactoring Code to RxJava, Looping locations and arraylist
Using RxJava 2 in arrays Merge values of two JSON Array into a JSONObject java
How to iterate over two arrays and filter data using RXJava?
Rxjava2, Retrofit2, download image as byte array
Using RxJava 2 in asynchronous RxJava - single thread asynchronous processing
How to aggregate different async sources into a Single using RxJava2?
How to organise chain of async calls in RxJava2 way
Writing subsequent API requests with RxJava2 in Java
RxJava 2: Observable.create() wait until async code is finished using Thread.sleep()
Propagating asynchronously calculated data back to the GUI thread
Perform a series of tasks with an interval in between each
Using RxJava 2 in backpressure RxJava2 Observable backpressure
Only consume latest item with onBackpressureLatest()
How to fix "MissingBackpressureException"
Converting an Observable to a Flowable with backpressure in RxJava2
What's the behavior of onBackpressureBuffer in RxJava2
How can a subscriber control a Publisher with reactive pull backpressure?
Create a flowable with generate function using RxJava2
Rxjava2 approach similar to backpressure for BiFunction
Using RxJava 2 in concurrency RxJava: Specifying maximum concurrency for a list of Completables
Using RxJava to fork into tasks and combine results
RX-java2 repeat consumption of an Observable
Using RxJava 2 in exception RxJava2 observable take throws UndeliverableException
RxJava2 UndeliverableException when orientation change is happening while fetching data
Mapping exception in RxJava 2
How to handle nulls in RxJava 2.x?
Observable.concat with Exception
RxJava 2 - Fatal Exception thrown on Scheduler
FATAL EXCEPTION: RxCachedThreadScheduler-1 when trigger dispose. Why?
Couchbase error: rx.exceptions.OnErrorThrowable$OnNextValue: OnError while emitting onNext value
Catch Exceptions when using Completable.blockingAwait()
getting java.io.InterruptedIOException while implementing instant search in android using RxJava2 and Retrofit
RxJava2 - Emit onError on parallel rail will get UndeliverableException
How to log a stacktrace of all exceptions of rxJava2?
Android - Using RxJava with Retrofit causes an IllegalArgumentException
Continue subscribing for data even after exception using rx notifications
Throwing Exception in a nested Flowable's onNext is causing an UndeliverableException
E/AndroidRuntime: FATAL EXCEPTION: RxNewThreadScheduler-42
How to throw custom exception with Retrofit2 and RxJava2
Fatal Exception thrown on Scheduler - rxJava2 in Android
Convert function into a completable with custom Exceptions
Cannot find symbol class EmptyResultSetException when using Android Room Database with RXJava2
InterruptedException not caught on RxJava onError callback?
Rx Java2 handle asynchronous timeout exception
Uncaught exception inside onNext being propagated to RxJava global exception handler
RxJava - Request processing failed with IndexOutOfBoundsException
RxJava - Request processing failed with IndexOutOfBoundsException
Why don't `OnErrorNotImplementedException` occurs in `onComplete` and `onNext`?
NetworkOnMainThreadException when Observable subscrible rxjava
Using RxJava 2 in flatmap What is the difference between using a compose() and a simple flatMap()?
RxJava - Any way to combine scan and flatMap?
RxJava2 passing data through flatMap on a Single
Using flatMap in RxJava 2.x
FlatMap and Subscribe in RxJava
RxJava2 flatMap create duplicate events
RxJava - groupBy, toMap and flatMap not working well together?
How can I merge both values using Single.flatMap?
Nested Single.flatMap in RxJava vs Single.zip, are the same?
FlatMap an iterable and combine it back into iterable
Null handling in rx-java2 flatMap
Rxjava - chain observables
RxJava - How to make flatmap continue if one of the observables causes an error?
Using RxJava 2 in functional programming RxJava: merge() changes the order of the emitted items?
RxJava - map different functions after a groupBy
Using RxJava 2 in gradle Exception in thread "main" java.lang.NoClassDefFoundError: org/reactivestreams/Publisher?
java.lang.NoClassDefFoundError: io/reactivex/subjects/Subject when building jar in Intellij Idea (gradle + JavaFX 11)
Using RxJava 2 in guava Convert a ListenableFuture chain to the equivalent RxJava structure
Collect items to Guava Multimap
Using RxJava 2 in interrupted exception How to handle dispose in RxJava without InterruptedException
Caused by: java.lang.RuntimeException: java.lang.InterruptedException
Using RxJava 2 in java 8 When is an observable chain triggered by main thread
Creating a Flowable that emits items at a limited rate to avoid the need to buffer events
RxJava v1 to v2
"Impossible" NPE in a multi-threaded situation
Identify which element is currently processed
Using RxJava 2 in java stream How to get rid of nested RxJava streams?
How can I divide a continuous RXJava stream on the fly based on the elements in the stream?
Is it safe to mix Java streams + Rxjava
How to create Observable<Integer> from infinite Stream<Integer> using RxJava2?
Using RxJava 2 in json Cast CSV file to JSON using RxJava2
Reading inner json object with retrofit and rxjava
Expected BEGIN_ARRAY but was BEGIN_OBJECT json
Using RxJava 2 in junit5 How to test if requests increase metrics while not getting any response in Vert.x?
Test an overridden method of an inner class with JUnit and Mockito
Using RxJava 2 in lambda Rewrite Java code in Kotlin using Function Reference occurs SAM types conflict
Void is not a functional interface
Why can't I use a method in a lambda?
How to fix "variable used in lambda expression should be final"?
Using RxJava 2 in micronaut RxJava equivalent of simple ThreadPoolExecutor example
micronaut petstore a code segment from java to groovy
Using RxJava 2 in mongodb Transform a Single of an object to a Single of an inner field of that same object in RxJava
Java Async MongoDB driver and RxJava2 Observables
Using RxJava 2 in multithreading How to parallel execute consumer in RxJava2?
Creating threads in Rxjava
RXJava2 reader Observable with concurrent subscribers
RxJava2 PublishSubject subscriber fails to receive items when called from multiple threads using SingleScheduler
How to create an async event bus using RxJava 2?
Observable.create() subscribeOn and observeOn not working
RxJava2 multithreading or something goes wrong
Why doesn't my RxJava timer application terminate?
Q : RxJava : How the clear (CompositeDisposable) method work internally
How can I replace inter thread communication using volatile variables with rxjava?
RxJava: How to handle events in multiple threads
RxJava: Thread pool for network calls
Have some trouble with thread work
Keep main thread wait until RxJava Observable complete
Using RxJava 2 in observable Do I have to unsubscribe from completed observable?
RxJava: Observable and default thread
Proper usage of Observable.create() in RxJava 2 (Best Practices)
How to handle errors in an Observable chain conditionally?
RxJava get result of previous observable in chained network request
rxJava debounce() operator not working with Observable.range()
Filter RxJava Observable with other Observable
Decorating observable
Rxjava - Group/Batch bursts of elements in an observable sequence
RxJava - Observable - multiple filter calls vs one filter call
Ignore errors in an Observable<Single<T>>
RxJava 2.0 - how to combine Observable and Completable
How to create Observable out of Runnable?
RxJava combining observables without repeating execution
How to combine a dynamic number of Observables in RxJava 2?
RxJava - Control one Observable by another one
Collect all observable strings in array list
Combine observables in the order of availability of its elements
Concat and return Observable
How to Make an Observable that Emits Combined Items Emitted by Another Observable in RxJava 2?
RxJava Observable.create not emitting events for switchIfEmpty(observable)
Will the Observable stop emitting midway in this scenario due to being garbage collected?
RxJava2 - observable.subscribe onComplete is Action type
RxJava zip with empty list of observables
Why does my RxObservable never fire?
Observable.take() causing NPE
Convert Observable<Single<Object>> to Single<List<Object>>
How to use observable in onComplete (Rxjava2)
Rx Java: Sleep before OnNext (Sleep before emitting from Observable)
RxJava - two observables
RxAndroid : How to emit zipped observable every minute?
passing responses between observables in RxJava/RxAndroid
Cant Merge RXJava2
RxJava -2 Observables that accepts more Observables at any time?
When does a ConnectableObservable terminates?
RX Java 2, Observable that accepts new values to be added
Make Observable return only when specific Boolean case is met
Observable.merge and debounce in RxJava
Create observable that combines two but is ruled by one
How to get notified of a observer's dispose action in a custom Observable in RxJava2
RxJava: How to make observable to create on different thread than main thread
Combine previous observable
RxJava 2 Observable that onComplete resubmits itself
How Convert to Rx java Observable
Subscribe on Observable Does Nothing
Observable and nested list in object
What happens when I unsubscribe from an Observable chain?
How to chain Observables dynamically by an iterable / list?
Continue subscribing for data even after error from Observable - rxjava
Setting an observable on a 5 second timer RXJava
How should I zip a List<Observable<T>> into an Observable<List<T>>?
Block ChannelHandlerContext when I use Observable from ReplaySubject
delay and interval operators do not work properly
RxJava, show updated list in Activity's onResume
Creating an Observable using RxJava
how to combine multi Observable<T> to Observable<List<T>> in Rxjava2
Is there an Observable which can make multiple 0 argument emissions?
How to chain an Observable if it depends upon the previous Observable?
Using RxJava 2 in okhttp RxAndroid and Retrofit: Unable to create call adapter for io.reactivex.Observable<retrofit2.Response<okhttp3.ResponseBody>>
RxJava2 + OkHttp Undeliverable exception: Socket Timeout
SocketTimeoutException unhandled by RxJava
Using RxJava 2 in picasso Picasso + RxJava2: Method call should happen from the main thread
Downloading photo with MVP pattern
Using RxJava 2 in project reactor How do I conditionally buffer a Grouped Observable/Flux based on Emitted Events?
OOM when using replay(selectorFoo) but not publish(selectorFoo)
rxjava2 branching logic based on number of emissions
Using RxJava 2 in reactive RxJava 2.x: Should I use Flowable or Single/Completable?
How to convert rxJava2's Observable to Completable?
Convert Maybe to Single from another source if Maybe completes
Is there an equivalent of Subject for RxJava's Single?
RxJava2: Alternative to rx.Observable method first(predicate)
RxJava2: Repeat conditonally / don't repeat in `repeatWhen`
How to properly transform multicasting observables in RxJava
RxJava2 zip two Flowables into one
Disable Flowable/Observable Buffer
RxJava2 idiom for combining two Maybes
BehaviorSubject subscribe on another thread
RxJava: How to express doOnFirst()?
RxJava: combine two optional observables
RxJava: remove element from list
RxJava: Can a result be split into two different observables?
How to Transform Observable<Observable<List<T>>> to Observable<List<T>>
How to pass output of a single to a completable in RxJava?
RxJava2 - How to write a custom logic of grouping items?
RxJava tricky startWith(Observable)
Take n elements at a time from a list in RxJava2
RxJava: behaviour of combineLatest
How to combine list of Completable tasks into one Completable result?
How to load relationed objects with RxJava
RxJava debounce operator depend on message
Concat vs ConcatArray RxJava
java.lang.NoClassDefFoundError: io.reactivex.Flowable
cannot resolve method 'subscribeon(io.reactivex.scheduler)'
How to iterate List using RxJava 2.1.7 Observable for Maven project?
'Incompatible type' error in emitting a String array in an Observable in RxJava 2
Group a list of events into a dictionary of events by date
Behavior of Observables and Observers in RxJava2
RxJava2 - last successful Single from concat
predicate filter rxjava2 - How to pass dynamic filter arguments
How do I use RxJava 2 to orchestrate a race with retry?
RxJava: OnNext Unsubscribe is not working
Emit item on timeout in Observable
File text change detection with rxjava
Group multiple emissions from different observables into one emission
Using else statements in RxJava
Rxjava: How to combine multiple observables without all observables completing?
Observable.just(doSomeLongStuff()) run doSomeLongStuff() before I subscribe to observable
Start RxJava2 Observable.interval() with no initial delay?
RxJava flat map: what happens when one of the resulting observable complete?
Chaining method calls using RxJava
How do I memoize the value emitted by a Single?
How to call observable that loads additional contents to a object transforming it in another observable?
Why "Maybe.doOnDispose" is not supported in RxJava2?
SubscribeOn and observeOn in the main thread
Use secondary/backup observable as long as primary observable hasn't emitted any value
Operator on RxJava Observable/Flowable to delay emission by n items
Convert CountDownTimer Cancel feature to RxJava
RxJava2 Completable does not combine as expected
Observable from iterable doesn't print all elements
Catch an error and return a new type in RxJava2
RXJava - Permanently switch observables when data is available on one of them
Span out values emitted by an Observable
What does share operator do in RxJava? When should I use it?
Vertx/RxJava/WebClient/ApiGateway/Reactive
How to pass the item indexes in Observable.fromIterable to onNext in subscribe method?
How to publish static collection with vertx and quarkus
Applying a Single to an ObservableSource and not over-reading
Ensuring order when calling methods that return a rx.Observable
Processing a list of rx.Observables
Android RxJava2 Handle Orientation Changed
How to adapt multithreaded observer-computation-rate to a cold Observable<List<T>>
How to return Observable with specific type?
Reactive Producer Consumer Observable in Java
Using RxJava 2 in realm Switch mapping Realm objects from Main to Background thread
Realm instance has already been closed, making it unusable
how can i merge filter realm result and network search in repository
Using RxJava 2 in repository pattern Create Flowable from while loop
Flowable from Cache and other Flowable for DataSource using RxJava
Using RxJava 2 in retrofit RXJava2: correct pattern to chain retrofit requests
Retrofit2 + RxJava2 + RxAndroid error
Cannot resolve symbol 'RxJavaCallAdapterFactory'
RxJava an Retrofit Network call subscribe
"No Instance of type variable R exist so that Observable conforms to Observable" Error when updating to RxJava2
RxJava - How to get Single from nested method
Zip operator in RxJava is not working with Retrofit
Databinding/Live data handle configuration changes with Retrofit/Rxjava
RxJava - making two calls where the first one is conditional
How to retry in RxJava2 only when the response is a 404
RxJava - get list of result data of 2 combined requests
RxJava2, Retrofit - doOnNext, doAfterNext, doOnComplete doesn't call
RxJava/Retrofit2/Java - NetworkBoundResource not working as expected
Retrofit 2 Class File issue
How do I make RxJava call onErrorReturn() and still execute onError()
Make multiple API requests with different request body sequentially
How can I use retrofit and RxJava with multiple pojo class?
RxJava Retrofit chain of requests with foreach loop
Retrofit 2 - RxJava : Unable to invoke no-args constructor for retrofit2.Call<RemoteDataObjectModel>
RXJava Retrofit returns POST HTTP Error 500
Refreshing access token when REST API returns 401 in Retrofit2 RxJava
Simplifying triple nested loop to avoid callback hell in android retrofit2 (via RxJava2?)
Waiting for two Observables to complete before proceeding?
Multiprocessing or Multithreading using rxjava2+retrofit is not working
Combine data from multiple API calls using retrofit and RxJava (Android)
RxJava 2 & Retrofit 2 sequential independent calls
RxJava 2 / Retrofit 2 call not being made
How to properly combine multiple requests with rxjava2?
Error while observing MutableLiveData
Problems with zip function in rxjava2
Using RxJava 2 in retrywhen Retrying an observable using retryWhen()
RxJava retryWhen retry the whole method that returns a completable
Use onErrorReturn with retryWhen in RxJava
RxJava2 using retryWhen with filter
Using RxJava 2 in rx binding RxJava not calling neither onSuccess nor onError, app freezing
Convert Kotlin Unit to Java Void
Using RxJava 2 in rx kotlin Get N last objects emitted by observable in RxJava2
Take elements until a certain character and group them with RxJava
Emit value if specific time has passed after last item
How to dynamically scale debounce of burst emission stream?
Customize ObservableTransformer with RxJav/RxKotlin2 when using with compose()
Rx Kotlin/Java Observable on state
Using RxJava 2 in rxandroidble Write/Notification handling with rxandroidble
Writing multiple commands to characteristic
MTU change following example
Using RxJava 2 in spring webflux Convert RxJava Single to Mono
Project Reactor composing Flux.zip()
Using RxJava 2 in spring Difference between creating new instance and using scope prototype annotation in Spring
Spring Data Cassandra Query DSL RxJava2
Using RxJava 2 in stream RxJava 2.0 - How to convert Observable to Publisher
rxJava2 Combining Single, Maybe, Completable in complex Streams
Missing class LiveDataReactiveStreams
RXJava2. Do I need dispose streams which emits once? (Single, Maybe)
RxJava 2: How to filter items of infinite stream that emits "List<Item>"?
Looking for Rxjava operator to merge sources into one stream
Keep stream alive even after onComplete()
How to combine multiple words into a sentence with RxJava2?
Cannot resolve method 'subscribe(anonymous org.reactivestreams.Subscriber<java.io.File>)
RxJava access item downstream
RxJava Flowable cache to Single deadlock
Using RxJava to write an infinite stream of grouped events to rotating files
How to let my rx stream react if my subscription is disposed?
How to make Files.lines AutoCloseable in Flowable.generate
RxJava 2: Why can't PublishProcessor subscribe to an Observable?
RxJava 2 - how to cancel infinite stream upon error and handle it?
rxjava 2: how to dispose a resource after downstream completes processing
Reactive Streams: How to wait for all publishers, by key?
Filter using Single<Boolean>
Confusion over creating RxJava2 reactive streams with .create()
create one stream of list of observables Rxjava 2
RXJava Subscription Inconvertible types; cannot cast 'void' to 'org.reactivestreams.Subscription?
Using RxJava 2 in testing How to handle mocked RxJava2 observable throwing exception in unit test
How to assert if a Completable has been subscribed/completed (RxJava2)
Testing RxJava2 doOnComplete()
How to assert two list of string using RxJava TestObserver?
How to unit test a list of objects using TestObserver in RxJava 2?
RxJava - Testing Single.zip() to ensure all arguments are executed
Debounce ignoring timeout in unit tests
Why is my RxJava subscription in unit test lost without being disposed
Why the merge operator is not returning the first observable that it receives?
RxJava 2: BehaviorSubject and Observable.combineLatest issues
How to mock an ObservableTransformer in unit tests using Mockito
unable to mock clientmethod returning Single<? extends HttpResponse> using Mockito