reactivex Questions
4
Solved
I am reading the official documentation of RxJS and then I realized they both are doing exactly the same thing.
To me they both seem exactly similar.
Please point out the difference between them if...
4
Stream.java
import io.reactivex.*;
public class Stream {
public static void main(String args[])
{
Observable.just("Howdy!").subscribe(System.out::println);
}
}
build.gradle:
group 'com...
4
Solved
In RxJS, there is a switchMap function. Is there an equivalent in ReactiveX/Rx.NET? I don't see one in the transforming documentation.
4
Solved
I want to observe the property UITextfield.editing. I'm using this code:
self.money.rx_observe(Bool.self, "editing").subscribeNext { (value) in
print("")
}.addDisposableTo(disposeBag)
But in th...
3
Solved
I have a need to detect when an observable (observedEvents) has been subscribed to, and then subscribe to another observable (triggerEvent). I don't want to subscribe to triggerEvent manually, but ...
Inellineloquent asked 14/6, 2017 at 22:20
1
How to plug a cancellation token into an existing IObservable pipeline before calling Publish on it (i.e., before it becomes an IConnectableObservable)?
This must be a part of a cold observable pip...
Psychotherapy asked 2/6, 2022 at 5:37
3
Solved
Getting an UndeliverableException while using completable
public Completable createBucketWithStorageClassAndLocation() {
return Completable.complete()
.doFinally(() -> {
Bucket bucket =
stor...
1
Solved
In ReactiveX paradigm, Is it a responsibility of the consumer (IObserver) to deal with thread safety?
E.g., if OnCompleted call comes along when OnNext is still executing on another thread?
It look...
Spunk asked 31/5, 2022 at 1:24
5
I'm missing something.
I recently watched the talk here, where the flutter devs are going through using the bloc development method with reactivex in Dart. If I'm using these streams and streamBui...
5
I have a list of items to parse, but the parsing of one of them can fail.
What is the "Rx-Way" to catch error but continue executing the sequence
Code Sample:
var observable = Rx.Obse...
Trembles asked 29/7, 2016 at 2:31
4
Solved
I am developing a Ionic2 App, using the cordova-plugin-network-information, I am subscribing to the connect and disconnect events from my app.ts and want to be able to pass a reference to my NavCon...
3
Solved
Based on this excellent SO answer I can get multiple tasks working in parallel in RxPy, my problem is how do you wait for them to all complete? I know using threading I can do .join() but there doe...
Colemancolemanite asked 15/5, 2017 at 21:33
4
Solved
I want my observable to fire immediately, and again every second. interval will not fire immediately. I found this question which suggested using startWith, which DOES fire immediately, but I then ...
2
Solved
In an app that connects to bluetooth devices, I am using the following function using RxKotlin:
private fun startBluetoothPair(device: BluetoothDevice) {
Observable.just(device)
.subscribeOn(Sch...
3
Solved
Is there an operator that can filter nil? The closest I've come is the solution mentioned here: https://github.com/ReactiveX/RxSwift/issues/209#issuecomment-150842686
Relevant excerpt:
public pro...
1
Solved
According to micronaut-data reactive guide,
"...
In the case of reactive execution and if the backing implementation is blocking, Micronaut Data will use the Configured I/O thread pool to sche...
Bedaub asked 22/10, 2020 at 15:40
4
Solved
Let's say we have an Observable:
var observable = Rx.Observable
.fromEvent(document.getElementById('emitter'), 'click');
How can I make it Complete (what will trigger onComplete event for all s...
Trochaic asked 4/12, 2015 at 20:47
3
Can someone explain me the difference between defer and create methods in Observable? I failed to understand when I should use defer and when should I use create ..
REFERENCES:
Defer: http://reac...
0
I have this code which I can use with concat but what I need is a way of passing Iterator so that I can add or remove items which isn't possible with this code.
I want to be able to remove and add...
1
In a lot of codebases using RxJS I seem to come across the pattern of exposing private Subjects as Observables via a getter or normal getObservable() function. My question is not why .asObservable(...
Esp asked 18/4, 2020 at 11:21
3
Solved
Faced the situation when it is necessary to make 10-12 small parallel queries and combine the results. But if there is a zip method that allows you to combine up to 9 Observables, then how to do mo...
Schick asked 20/8, 2018 at 0:20
2
Solved
I have infinite stream of events that can emit some consecutive event portions and I want to take one event per 1000 each milliseconds.
I tried debounceTime / auditTime / throttleTime but they doe...
4
I'm trying to get my head around the golden rule (if any) about:
When to use BehaviorSubject ?
and
When to use PublishSubject ?
The difference between them is very clear
There are man...
3
Solved
Let's consider the following simplified situation:
We have an Observable apples of type Observable < Apple >
Every Apple object has a method isRotten() which returns an observable of type Obs...
3
Solved
I'm trying to implement something like this:
// This obviously doesn't work, because we try to refer to `a` before it exists.
// c and m are some Observables.
const aSampled = a.pipe(
rxjs.operat...
Selfexamination asked 21/9, 2019 at 22:6
1 Next >
© 2022 - 2025 — McMap. All rights reserved.