0 votes
1 answer
26 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 ...
asked Jan 1 at 7:280 votes
1 answer
71 views
RxJava3 groupBy emitting individual groups instead of grouping by keyWorking 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 ...
asked Dec 5, 2024 at 0:060 votes
1 answer
33 views
Merge Flowable with filtered elements updated by batch anyc operationI 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 ...
asked Nov 29, 2024 at 13:52 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 ...
asked Nov 19, 2024 at 21:300 votes
2 answers
74 views
Unbounded backpressure in Flowable rxjava3Reactive 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 ...
asked Oct 22, 2024 at 8:58 ClassCastException in Production Build after Login in Android AppI'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 ...
asked Sep 25, 2024 at 11:530 votes
1 answer
30 views
adjust delay value in rx java from sourceI'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 ...
asked Feb 29, 2024 at 3:330 votes
1 answer
28 views
Can't get results from RXJava subscribeI'm new to RXJava. I have this code Observable.just( getAllImagesFromFirebaseStorage( spotsList.get(i).getName(), spotsList....
asked Jan 24, 2024 at 3:250 votes
1 answer
35 views
retry on Single not getting hit on serverreturn Single.fromFuture( asyncStub.withDeadlineAfter(ClientConfiguration.INSTANCE.getMaxTimeout(), TimeUnit.SECONDS).checkBalance(payload)) .doOnSubscribe(s -> System.out.println(&...
asked Jan 7, 2024 at 14:570 votes
1 answer
32 views
RxJava subscribeOn conditionallyI would like to apply subscribeOn based on the condition on Observables. For example in the below code Observable.just("One", "Two", "Three") .flatMap(v -> ...
asked Nov 7, 2023 at 13:460 votes
0 answers
55 views
If you cancel/dispose DisposableSubscriber, onComplete event is not calledUsing this code: Disposable d = Flowable.range(1, 5) .subscribeWith(new DisposableSubscriber<Integer>() { @Override ...
asked Aug 26, 2023 at 13:470 votes
0 answers
33 views
rxjava: thenReturn Single.error vs thenThrow ExceptionI am writing an unit test for methodOne and am trying to simulate an exception scenario. Single<String> methodOne() { methodTwo(); return Single.just("Hello"); } Single<...
asked Aug 4, 2023 at 18:391 vote
0 answers
48 views
how to get main thread variables in RxJava3Say 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"); ...
asked Jul 18, 2023 at 4:461 vote
0 answers
61 views
RxJava compatibility with RsocketIm 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 ...
asked May 30, 2023 at 9:290 votes
1 answer
633 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-...
asked May 27, 2023 at 16:24RetroSearch is an open source project built by @garambo | Open a GitHub Issue
Search and Browse the WWW like it's 1997 | Search results from DuckDuckGo
HTML:
3.2
| Encoding:
UTF-8
| Version:
0.7.4