rx-java Questions
3
Solved
I need to implement following behavior:
Make a REST post request
If response returns with a status 429 Too many requests, retry up to 3 times with a delay of 1 second
If the third retry fails or ...
Hutchinson asked 16/9, 2019 at 14:42
2
What kinds of exceptions I should consider while working with Android Room.
From my research I found out that there is only one exception that might occur.
Room Exceptions
That is also when you a...
Gap asked 7/11, 2018 at 2:58
3
Solved
In our app I download an image file with this code. I need to show download progress(downloaded bytes in percentage) on UI. How I can get download progress in this code? I searched for solution, bu...
4
Solved
I'm going to send a simple get method to my server(it is Rails app) and get the result using RxJava and Retrofit. The thing that I did is:
My interface:
public interface ApiCall {
String SERVICE...
Imp asked 16/4, 2017 at 5:34
4
I want to call a function (synchronously) and then use its return value as an initial emission (subsequently chaining some other operators on the resulting observable).
I want to invoke this functi...
Alberthaalberti asked 2/1, 2017 at 19:31
2
Solved
I'm using retrofit 2.0.0-beta2 and debug build is working properly but I'm getting the following error on release build with Proguard.
Here's the updated logcat errors.
11-17 18:23:22.751 16274-1...
Nonie asked 17/11, 2015 at 10:51
9
Solved
I am using rxjava and rxvolley on my android aplication. When I try to run it I get this error
Execution failed for task ':testapp:transformResourcesWithMergeJavaResForDebug'.
> com.android.bui...
Autoplasty asked 1/2, 2017 at 1:39
5
I am trying to find the main thread for subscribeOn in Rx3
Single.just(getHeavyData())
.subscribeOn(Schedulers.io())
.observeOn(AndroidSchedulers.mainThread())
.subscribe(new Consumer<Data&g...
Ohg asked 16/10, 2019 at 13:26
5
Solved
I have a Single from RxJava and want to continue working with a Deferred from Kotlin Coroutines. How to accomplish that?
fun convert(data: rx.Single<String>): kotlinx.coroutines.Deferred<...
Bandeau asked 16/5, 2020 at 12:50
9
Solved
@DELETE("/job/deletejob")
Observable<JobDeleteResponseModel> jobDelete( @Body JobDeleteRequestModel model);
am getting this error:
Non-body HTTP method cannot contain @Body or @T...
8
Solved
I am having a lot of trouble understanding the zip operator in RxJava for my android project.
Problem
I need to be able to send a network request to upload a video
Then i need to send a network re...
4
Solved
I'm just practicing RX Java and wanted to get the position in an array for items which match a filter. I can't see any obvious way to do it. I was looking at maybe zipping a range and iterable obse...
8
Solved
The rxjava doc definition of switchmap is rather vague and it links to the same page as flatmap. What is the difference between the two operators?
Doriadorian asked 27/1, 2015 at 16:51
5
Solved
In android i use Timer to execute task that repeats every 5 seconds and starts after 1 second in this way:
Timer timer = new Timer();
timer.scheduleAtFixedRate(new TimerTask() {
@Override
publ...
Odetteodeum asked 27/7, 2016 at 6:17
5
Solved
Background: I have a function:
def doWork(symbol: String): Future[Unit]
which initiates some side-effects to fetch data and store it, and completes a Future when its done. However, the back-end...
3
Solved
I have a sleep method for simulating a long running process.
private void sleep() {
try {
Thread.sleep(2000);
} catch (InterruptedException e) {
e.printStackTrace();
}
}
Then I have a metho...
Helsell asked 6/7, 2016 at 21:33
15
Solved
Consider the following use case:
need to deliver first item as soon as possible
need to debounce following events with 1 second timeout
I ended up implementing custom operator based on Operator...
Sterlingsterlitamak asked 9/5, 2015 at 12:40
3
Solved
I realize that I am using subscribeOn()/observeOn() on the MainThread.
What are the set of options I can pass into subscribeOn()?
What are the set of options I can pass into observeOn()?
12-17 21:...
9
Solved
I am chaining async operations using RxJava, and I'd like to pass some variable downstream:
Observable
.from(modifications)
.flatmap( (data1) -> { return op1(data1); })
...
.flatmap( (data2...
Coburn asked 27/1, 2015 at 17:12
3
Solved
When should we use doOnNext() from Observable instead of just onNext()?
3
Solved
Getting an UndeliverableException while using completable
public Completable createBucketWithStorageClassAndLocation() {
return Completable.complete()
.doFinally(() -> {
Bucket bucket =
stor...
17
Solved
I'm struggling to implement something I assumed would be fairly simple in Rx.
I have a list of items, and I want to have each item emitted with a delay.
It seems the Rx delay() operator just shif...
4
Solved
Let's say I have two infinite Observables that can emit values at any moment. They combine to create a Observable<ProcessFileEvent>.
Observable<Integer> selectedFileId= ...
Observable&...
Anse asked 8/7, 2015 at 19:45
0
I'm getting an unwanted behavior/flaw when passing a list of Observable Network calls to Observable.Zip(), similar to this accepted answer:
How to make multiple request and wait until data is come...
Straub asked 16/4, 2022 at 0:2
1
Solved
We're refactoring our project from RX to Kotlin Coroutines, but not in one go, so we need our project use both for some time.
Now we have a lot of methods that use RX single as a return type like t...
Wearing asked 28/3, 2022 at 11:7
1 Next >
© 2022 - 2025 — McMap. All rights reserved.