rx-java2 Questions
3
I'm Trying to load some data from a web server in my application. And Because of the async nature of the operation, there is no way to know ahead of time how long it will take to complete. To alert...
1
I migrated from paging 2 to paging 3. I tried to implement ItemKeyedDataSource of Paging 2 to Paging library 3. But the problem I was facing is, the same value(currentJodId) was passed as the nextk...
Stoops asked 13/9, 2020 at 11:13
3
Solved
I am using RxJava3 and retrofit but I am unable to get a rxjava3 retrofit-adapter for RxJava3.
7
Solved
I initialize my variable like this:-
val user: BehaviorSubject<User?> user = BehaviorSubject.create()
But I can't do this. IDE throws an error:-
user.onNext(null)
And doing this, IDE s...
5
Solved
I have two Completable. I would like to do following scenario:
If first Completable gets to onComplete , continue with second Completable. The final results would be onComplete of second Completabl...
2
Solved
debounce, throttleFirst, and throttleLast are most conspicuously absent from Project Reactor's Flux. Do they have any counterparts?
Rimester asked 18/6, 2017 at 17:55
4
I am looking for what is the recommended practice in rxjava2 to handle a case where one flowable leads to conditional behaviors.
More concretely, I have a Maybe<String> for which I want to U...
4
I'm asking this from an Android perspective, but this should apply to RxJava in general.
As a best practice, should my view always dispose of even short lived Completable, Single, Maybe and termin...
5
Solved
I'm using version 2.0.0 of RxJava, and it seems like I have no access to AndroidSchedulers. I'm unable to get access to mainthread through RxJava
6
I am using RxJava2 in my android project.
I am using the following code to create the Observable
public Observable<AlbumDetails> loadAlbumFromAlbumId(final String albumId) {
return Observ...
Inquiline asked 3/5, 2017 at 17:59
5
Solved
I'm new to the new architecture component WorkManager, I do my API calls via Retrofit and RxJava.
My use case here is to get new posts from the Backend, then show notification, and update a widget...
Remnant asked 8/8, 2018 at 22:5
4
Solved
I'm learning RxJava and I noticed a lot of the sample code does a isDisposed() check before calling dispose(). I did not notice any issues when I called dispose() on an already disposed Disposable....
2
Solved
How do I convert a Flowable to a Single? Or if there's another way to make it stop emitting after the first response that is also of interest.
I've tried this but it doesn't seem to work:
dispos...
2
Solved
I am trying to use new Android Architecture Components. I'dd like to convert Rx Flowable to LiveData with LiveDataReactiveStreams but the class is missing.
Here are my dependencies:
compile "andr...
Shrier asked 22/5, 2017 at 11:26
3
Solved
I want to generate sdk using swagger codegen which can give me generated sdk with Observable as callback like below :
@POST("oauth/token")
Observable < TokenResponse>
getRepository(@Query("...
Pisci asked 8/12, 2016 at 13:43
4
Solved
I'm trying to understand the purpose of this library by Jake Warthon:
https://github.com/JakeWharton/RxRelay
Basically: A Subject except without the ability to call onComplete or
onError. Subj...
Polyhydroxy asked 5/8, 2017 at 6:2
2
I am new to Room, Rxjava and other android architecture components. I am trying to update/insert 2 records (If row already exists,update it. otherwise insert a new row.) I have tried to do it in fo...
Discoverer asked 14/4, 2018 at 9:17
4
Solved
I am trying to filter the list on the basis of it's property. For example, Sensors class has a property isActive and I want to get all the objects with isActive as true but I am unable to do it. I ...
Alejoa asked 8/2, 2018 at 12:12
1
tried with multiple ways still facing this issue as
I am using RxJava and Retrofit to do all my network operations. Below is my code.
<-- HTTP FAILED: java.net.SocketException: Socket close...
3
Solved
Can anyone please explain the difference between Observable, Completable and Single in RxJava with clear examples?
In which scenario we use one over the others?
3
Solved
Search is central in my app and I need it to work well. Right now I have a SearchView. I need to display the results inline, so I'm using this code.
searchView.setOnQueryTextListener(new SearchVi...
Alleenallegation asked 26/3, 2017 at 20:15
3
Solved
I am in the process of getting to know RxJava. I started using it in one of my personal apps and would like to unit test the code but having some difficulties and would like some help.
The scenar...
Sedillo asked 3/10, 2017 at 16:35
3
Solved
Kotlin 1.3.72,
RxJava2
I have the following code and I am trying to avoid using the !! operator, but not sure why it thinks the value is null and I need to use the safe call operator.
Later on I ha...
4
Solved
What is the difference between rxjava2 dependency and rxkotlin dependency.
If I'm using rxkotlin dependency, should i need to add rxjava2 dependency along with that.
implementation 'io.reactivex....
5
So I'm trying to completely clear my tables upon user log out but deleting the tables does not seem to stick and the old data is still there when another user logs in. I'm using RXJava Completables...
Shiller asked 26/7, 2018 at 17:24
© 2022 - 2024 — McMap. All rights reserved.