I am using Polidea's RxAndroidBle library to communicate with a Device in my Android application. I am very new to Reactive Programming so I can't figure out exactly how to do the following: Se...

I have implemented a Service that receives notifications sent from the server. I'm currently using a broadcast receiver to send data. The Broadcast Listener is updating the Activity just fine. How...

I'm studying Rxjava2 and I'm trying to integrate the Room Library with Rxjava2. The problem is: I have a populated table and every time I login in the app, I need to delete this table and then inse...

I have to spend a lot of time learning and implementing Livedata (especially MediatorLivedata) in business logic because it helps to add data from various sources. Had a success with it, because I ...

I am trying to get some insights on a chunked endpoint and therefore planned to print what the server sends me chunk by chunk. I failed to do so so I wrote a test to see if OkHttp/Retrofit are work...

In my Android application after successful login I'm saving session info in Room, then I'm retrieving user information from BE and saving it too. Everything works fine. I can see saved information ...

I want to handle clicks in such a way that they are ignored as long as I'm doing processing of some click that occurred. I thought I could do it by utilizing the backpressure, like this: private ...

In http://reactivex.io/RxJava/javadoc/io/reactivex/Observable it is stated: The Observable's operators, by default, run with a buffer size of 128 elements (see Flowable.bufferSize(), that can be...

I am attempting to developed an Android application based on the following talk presented by Jake Wharton The State of Managing State with RxJava 21 March 2017 – Devoxx (San Jose, CA, USA) Jake ...

I am dealing with the problem. I am trying to call RxJava in the sync manner, however doing that results in blocking the Main thread. Here is my code @Override public Single<SettingsBund...

Hi I'm new with RxJava and Kotlin and I loose some concepts about it. I have "api" like this: interface VehiclesService { @GET("/vehicles/") fun getVehicles(): Single<List<Vehicle>>...

I have the following synchronous code that I would like to model as async code in RXJava. void executeActions(List<Action> action) { if (action == null || action.size() == 0) return; for ...

In room the @Delete annotation doesn't emit anything. This is what the dao looks like @Dao public interface UserDao { @Delete void deleteUser(User user); //We can't use Maybe or Single or anyt...

I am using RxJava/Kotlin with Room and Retrofit. I am sure I'm not making something write as I just started learning RxJava. The scenario is that I make a call to check if there are favorite record...

My current Android Application employs Retrofit and RxJava to choreograph my network calls. I have modelled my HTTP GET(s) as Single<Response<String>> and POST(s) as Completable. The ...

During debugging of Android app, sometimes InterruptedException occurs and crashes the app. I've been able to set a break-point on default exception handler, but call stack is not informative. at ...

I would like to load a list of cars from the internet into a ListView in a Widget. When I am requesting the cars in the onDatasetChanged method, it does not update the list. When I however manually...

I'm calling an API using Retrofit 2 and RxJava2. If a call fails, in some cases (e.g. no Internet connection), I want to display an error dialog to the user and let him retry. As I'm using RxJava,...

I have the following rxJava chain: override fun combineLocationToPlace(req: Flowable<Place>): Flowable<Place> { var combinedFlowable = Flowable .combineLatest( req, getLastLocatio...

When I subscribe({}) to an Observable in a Singleton class, do I need to call .dispose() method at some point? and if yes, when and where? because a singleton will remain until the App is running. ...

I've been using alot of RxJava Observables converted to LiveData in my code using LiveDataReactiveStreams.fromPublisher() library. So I though of adding an extension function to the RxJava Observab...

In RxJava 1 subscribing with an Observer returned a Subscription which could be unsubscribed. In RxJava 2 subscribing with an Observer returns void and no Disposeable. How is it possible to stop t...

I am very excited with new RxJava Sources such as: Single, Maybe, Completable, which make your interfaces classes cleaner and prevent from a lot of mistakes during create of your 'Source' (e.g. for...

I have been using Subjects in Rxjava for quite awhile but today a new term came up: PublishProccessor would you please explain me the difference of the Processors and Subjects? I have gone throug...

I use combineLatest() to combine 3 streams of observables. All these are combined so that all data in the UI is shown at the same time. Now, there is a scenario in which one of the observables won'...