Question: In my app, I am using ffmpeg-kit and execute a command that record/capture any stream using the internet and writes it to the device’s internal storage. This command or stream can run until the user stops. And from here ...
Question: I am trying to add dynamic internal for the list items that have been emitted using RxJava. Currently in my flow after every 10 seconds I am emitting the items but what I am trying to achieve is there ...
Question: I am trying to simulate the delay while emitting items in a specific sequence Here I am trying to simulate the problem The output of the above code is what I am expecting is to perform an operation once ...
Question: I need my request to repeat once every 30 seconds. How can I force repeatWhen in this code? Answer: You need to add this before subscribeOn to repeat the same request: So it will call the same request every ...
Question: I have some issue when I try to catch exception. I have some method like this (legacy method) : and I need to send a Single of this part and my solution is: are there a way to handle ...
Question: Imagine there are two BehaviourSubject with Strings: were I update location each like Then I have a enum class used in a Observable: I combine the above Subjects and Observables via combineLatest(): Now I would like to extend a ...
Question: I want to subscribe to an observable when it’s already running. E.g. I create an observable to emit some upload percentage somewhere in the app, and start that upload. When users launch another app screen, I need to show ...
Question: I have a PublishSubject: subjectA = PublishSubject.create() whoch is then operated similar to: Thinking that above code created following log output: RX global error io.reactivex.rxjava3.exceptions.OnErrorNotImplementedException: The exception was not handled due to missing onError handler in the subscribe() method ...