147 questions
0
votes
1
answer
31
views
How to make Flowable stop emitting data after one call in Kotlin?
I am using rxjava3 in my case I want to get paging data that comes as flowable from android paging with initial data from another API I want to use zip operator to call both only for first time then ...
- 342
0
votes
1
answer
74
views
RxJava3 groupBy emitting individual groups instead of grouping by key
Working on updating my app from RxJava2 to RxJava3. I know there are some updates to how groupBy works from reading the documentation, but I'm having trouble understanding why I'm seeing this ...
0
votes
1
answer
46
views
Merge Flowable with filtered elements updated by batch anyc operation
I have rxjava3 Flowable having Item objects and want to run async operation in batches only for elements matching a condition. Then I want to allow downstream operators to iterate over original Item ...
- 492
1
vote
1
answer
44
views
How to handle multiple subscriptions in a fair manner?
I need to handle different types of events in a strict one by one manner, but in a background thread.
According to the documentation, the next code, Schedulers.from(executor, false, true);, should ...
- 1,422
0
votes
2
answers
99
views
Unbounded backpressure in Flowable rxjava3
Reactive Streams is built around back pressure what is great and I would like to better understand how to use RxJava3 API. The approach to drop overflow data for GUI events is perfectly fine but if I ...
- 492
1
vote
1
answer
92
views
ClassCastException in Production Build after Login in Android App
I'm encountering a ClassCastException in my Android application that occurs after the login screen when the app is uploaded to the Play Store. The application works fine in development, but it crashes ...
- 21
0
votes
1
answer
38
views
adjust delay value in rx java from source
I'm new to Rxjava and could not find an example or appropriate usage of single.delay() that uses the result of the previous flatmap as the delay. My aim is to use the result of functionOne() to set ...
- 13
0
votes
1
answer
28
views
Can't get results from RXJava subscribe
I'm new to RXJava.
I have this code
Observable.just(
getAllImagesFromFirebaseStorage(
spotsList.get(i).getName(),
spotsList....
- 310
0
votes
1
answer
48
views
retry on Single not getting hit on server
return Single.fromFuture(
asyncStub.withDeadlineAfter(ClientConfiguration.INSTANCE.getMaxTimeout(), TimeUnit.SECONDS).checkBalance(payload))
.doOnSubscribe(s -> System.out.println(&...
0
votes
1
answer
35
views
RxJava subscribeOn conditionally
I would like to apply subscribeOn based on the condition on Observables.
For example in the below code
Observable.just("One", "Two", "Three")
.flatMap(v ->
...
0
votes
0
answers
60
views
If you cancel/dispose DisposableSubscriber, onComplete event is not called
Using this code:
Disposable d =
Flowable.range(1, 5)
.subscribeWith(new DisposableSubscriber<Integer>() {
@Override
...
- 11k
0
votes
0
answers
37
views
rxjava: thenReturn Single.error vs thenThrow Exception
I am writing an unit test for methodOne and am trying to simulate an exception scenario.
Single<String> methodOne() {
methodTwo();
return Single.just("Hello");
}
Single<...
- 1
1
vote
0
answers
50
views
how to get main thread variables in RxJava3
Say I have some variables stored in ThreadLocal and how can I fetch them in below 'mapper' method?
ThreadLocal<String> data = new ThreadLocal<>();
data.set("some data");
...
- 1,491
1
vote
0
answers
62
views
RxJava compatibility with Rsocket
Im going through RSocket implementation for Java using this https://github.com/rsocket/rsocket-java, but could only find Reactor support(Flux,Mono)
I cannot see any RxJava(Observables) support with ...
0
votes
1
answer
674
views
For RXJava Observable doFinally is not called even after onComplete. Is there a way to explicitly called doFinally?
I have the following code which creates a simple Observable, emits an Integer and calls onComplete. According to https://medium.com/@ValCanBuild/making-rxjava-code-tidier-with-doonsubscribe-and-...
