Skip to content Skip to sidebar Skip to footer
Showing posts with the label Rx Java

How To Repeat Same Network Request Multiple Times(different Parameters) In Rxjava/rxandroid?

So, I have a /download API which returns me a generic Object (based on an index number which is its… Read more How To Repeat Same Network Request Multiple Times(different Parameters) In Rxjava/rxandroid?

How To Pass Custom Pojo As Parameter To The Interface Method Call In Rxjava2 Observable?

Current code Observable.from(listMovie)//list of movie .flatMap(new Func1 >() { … Read more How To Pass Custom Pojo As Parameter To The Interface Method Call In Rxjava2 Observable?

Caused By: Rx.exceptions.missingbackpressureexception

I have an other problem. This time I am facing this error Caused by: rx.exceptions.MissingBackpress… Read more Caused By: Rx.exceptions.missingbackpressureexception

Rxjava Retrofit Parse Api Error For User

I'm using RxJava with retrofit in a library project. Everything is working fine, I get the expe… Read more Rxjava Retrofit Parse Api Error For User

Why Is Oncomplete Not Called In This Code? (rxandroid)

I know OnComplete of a Observer is called when all the items are emitted. In the below code, I am p… Read more Why Is Oncomplete Not Called In This Code? (rxandroid)

Android Mvvm - Update Viewmodel When Data Changes

I'm working on an app using the MVVM pattern with RxJava. The architecture is the following: I… Read more Android Mvvm - Update Viewmodel When Data Changes

Uploading Multiple Image To Aws Server Using Rxjava

I am trying to upload multiple image to ASW using rxJava. I have found a kotlin example. Upload mul… Read more Uploading Multiple Image To Aws Server Using Rxjava

Repeat/resubscribe To Observable With Condition Based On Emitted Item(s)

I have enum-values that will be emitted by an Observable: public enum BleGattOperationState { S… Read more Repeat/resubscribe To Observable With Condition Based On Emitted Item(s)

Android.os.networkonmainthreadexception Using Rxjava On Android

i'm having trouble implementing rxJava in order to check if there is internet connection on and… Read more Android.os.networkonmainthreadexception Using Rxjava On Android

How To Wait Multiple Nested Async Calls By Using Of Rxjava-android?

I'm new to RxJava, here's my case, send request A and will get List back for each A, send… Read more How To Wait Multiple Nested Async Calls By Using Of Rxjava-android?

Call A Function After Retrofit And Rxjava Completes

Here's my code final ApiInterface apiInterface=restAdapter.create(ApiInterface.class); apiInter… Read more Call A Function After Retrofit And Rxjava Completes

Rx Java Observable Execute Until Some Condition

I am trying to find a way to execute observable until some condition is met. Consider the following… Read more Rx Java Observable Execute Until Some Condition

Googleapiclient Must Not Be Null [awareness Api]

I'm trying to find out why the Google Play Services is crashing with a nullpointerexception aft… Read more Googleapiclient Must Not Be Null [awareness Api]

Filter A Response Using Rx And Retrofit

I have a call in Rx like so: rxHelper.manageSubscription(HavocService.getInstance().getHavocAPI().g… Read more Filter A Response Using Rx And Retrofit

Rxjava Operator Debounce Is Not Working

I want to implement place autocomplete in Android application, and for this I'm using Retrofit … Read more Rxjava Operator Debounce Is Not Working

Rxjava: How To Handle Combinelatest() When One Of The Streams Emits Nothing

I use combineLatest() to combine 3 streams of observables. All these are combined so that all data … Read more Rxjava: How To Handle Combinelatest() When One Of The Streams Emits Nothing

Rxjava Group Two Responses One Of Which Might Be Null With Zip Operator

I want to make two concurent request to Realm database and return results with RxJava. The issue is… Read more Rxjava Group Two Responses One Of Which Might Be Null With Zip Operator

How To Combine Multiple Rxjava Chains Non-blocking In Error Case

My requirements: N Retrofit calls in parallel Wait for all calls to finish (success or failure) … Read more How To Combine Multiple Rxjava Chains Non-blocking In Error Case

Am I Using Flatmap Correctly To Merge Results From Multiple Api Calls?

I want to make multiple API calls (with three different queries) and merge the results and then dis… Read more Am I Using Flatmap Correctly To Merge Results From Multiple Api Calls?

Pause Between Call Onnext In Rxjava

How to make delay between onNext method calling? I have a code: Observable obs = Observable.range(… Read more Pause Between Call Onnext In Rxjava