-1 votes
1 answer
35 views
What is the idiomatic use of HiveMQ client's `subscribePublishes` methodI cannot figure out how to use the FlowableWithSingle<Mqtt5Publish,Mqtt5SubAck> subscribePublishes(Mqtt5Subscribe subscribe) method of the HiveMQ Rx client API. It returns FlowableWithSingle ...
asked Apr 24 at 17:470 votes
0 answers
38 views
RxJava BehaviorSubject.onNext() is called but subscriber is not receiving updatesI am trying to implement background polling in an RxJava-based Android application where: A repository periodically fetches data from an API every 10 seconds and emits updates via a BehaviorSubject. ...
asked Feb 14 at 1:020 votes
1 answer
38 views
How to cancel the Flowable upstream's block logic when a TimeoutException throwsI have a rxjava2 code, like below: public class Demo { /** @noinspection ResultOfMethodCallIgnored*/ @SuppressLint("CheckResult") public static void test() { Flowable....
asked Oct 31, 2024 at 7:340 votes
2 answers
78 views
Fire and forget coroutine jobHere is a the actual code in Rxjava. Its a fire and forget database operation fun saveResponseToDb() { Observable.just(database) .subscribeOn(Schedulers.io()) .observeOn(...
asked Aug 9, 2024 at 12:40-1 votes
1 answer
53 views
RxJava strip bytes at regular interval from a stream and then further extract messages based on length indicator of message bytesI have a Java inputstream, that I skip 2 bytes every n bytes. Now the output of that are bytes that are clean after stripping the 2 delimiters every n bytes. This output is a series of bytes where the ...
asked Jul 7, 2024 at 0:430 votes
1 answer
103 views
How to trigger recomposition when observing LiveDataI'm migrating an app from views to compose and am trying to trigger a schedule update every five minutes in which if there is a change in the data compose should recompose. Still using RxJava in my ...
asked May 10, 2024 at 21:200 votes
1 answer
34 views
Getting Compilation Failure "cannot find symbol for concatMap" in the RxJava CodeI am new to this RxJava coding language. I am trying to write a function that recursively copies files from one S3 location and pastes the content to another S3 location. Here is the code that I have ...
asked Apr 4, 2024 at 6:260 votes
1 answer
877 views
IllegalStateException: Reading a state that was created after the snapshot was taken or in a snapshot that has not yetAssume simplfied class like: class MyModel() { companion object val number = mutableStateOf(0) init { refresh() } fun refresh() { RestClient.getNumber() ...
asked Apr 4, 2024 at 0:222 votes
0 answers
46 views
Where do I put the Disposable for RxJava?I'm using RxJava2 and subscribing to my data streams with a CompositeDisposable variable. I'm familiar with codebases having the disposable in the Fragment/Activity, but I'm not entirely sure why that ...
asked Apr 2, 2024 at 0:50 RxJava PublishSubject buffer elements with timeoutI want to achieve the following with RxJava: Buffer elements and publish them when 5 seconds passed after the last element Publish buffered elements in 20 seconds passed after the first element ...
asked Mar 25, 2024 at 16:290 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
57 views
retryWhen hanging after migrating from rxjava to rxjava2We have the following methods which we have recently migrated from rx-java to rx-java2: @Override public Observable<FooResponse> doFoo(String id) { return api.doFoo(id) .map(Response::...
asked Jan 26, 2024 at 12:050 votes
1 answer
32 views
How to update the first observable with the data of the second dependent on the firstIn Android using Retrofit combined with RxJava I get an object Observable. Inside I have a List; inside Table I have properties containing a foreign key from the object Product. My goal is to get the ...
asked Jan 10, 2024 at 8:210 votes
0 answers
77 views
RxJava2 onNext can't execute after FlowableEmitter.onNext executed many timesI called the Flowable.create to implement that loop read data from bluetooth sockete InputStream, I try the below pseudocode to implement this. // connectBluetoothFlowable is a Flowable<Boolean> ...
asked Dec 19, 2023 at 10:090 votes
0 answers
41 views
Android: NPE: Observable.takeLastI set up some observables like so companion object { var isLocationToolActive: BehaviorSubject<Boolean> = BehaviorSubject.createDefault(false) var isAoIToolActive: ...
asked Dec 4, 2023 at 19:25RetroSearch 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