I cannot figure out how to use the FlowableWithSingle<Mqtt5Publish,Mqtt5SubAck> subscribePublishes(Mqtt5Subscribe subscribe) method of the HiveMQ Rx client API. It returns FlowableWithSingle ...

I 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. ...

I have a rxjava2 code, like below: public class Demo { /** @noinspection ResultOfMethodCallIgnored*/ @SuppressLint("CheckResult") public static void test() { Flowable....

Here is a the actual code in Rxjava. Its a fire and forget database operation fun saveResponseToDb() { Observable.just(database) .subscribeOn(Schedulers.io()) .observeOn(...

I 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 ...

I'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 ...

I 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 ...

Assume simplfied class like: class MyModel() { companion object val number = mutableStateOf(0) init { refresh() } fun refresh() { RestClient.getNumber() ...

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 ...

I 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 ...

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 ...

We 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::...

In 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 ...

I 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> ...

I set up some observables like so companion object { var isLocationToolActive: BehaviorSubject<Boolean> = BehaviorSubject.createDefault(false) var isAoIToolActive: ...