You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
It is imperative to be able to complete the previous observable docs:
Returns an Observable that emits items based on applying a function that you supply to each item emitted by the source Observable, where that function returns an (so-called "inner") Observable. Each time it observes one of these inner Observables, the output Observable begins emitting the items emitted by that inner Observable. When a new inner Observable is emitted, switchMap stops emitting items from the earlier-emitted inner Observable and begins emitting items from the new one. It continues to behave like this for subsequent inner Observables.
Or maybe you can provide some advice?
Example case:
func main() {
observable := rxgo.Just(1, 2, 3)().FlatMap(func(i rxgo.Item) rxgo.Observable {
println("new item", i.V.(int))
return rxgo.Interval(rxgo.WithDuration(time.Second * 1))
})
for el := range observable.Observe() {
println(el.V.(int))
}
}
I want to make a new observable each time after Just or other Observable creators emit a new value. In this case nice to unsubscribe from interval and create new observable
P.S Well, as I can see the flat map operator doesn't work too
output
new item 1
0
1
2
3
4
5
6
The text was updated successfully, but these errors were encountered:
Hello! One of the best RX operators is SwitchMap, it looks like FlatMap, but this operator stops previous observable
https://rxjs.dev/api/operators/switchMap
It is imperative to be able to complete the previous observable
docs:
Returns an Observable that emits items based on applying a function that you supply to each item emitted by the source Observable, where that function returns an (so-called "inner") Observable. Each time it observes one of these inner Observables, the output Observable begins emitting the items emitted by that inner Observable. When a new inner Observable is emitted, switchMap stops emitting items from the earlier-emitted inner Observable and begins emitting items from the new one. It continues to behave like this for subsequent inner Observables.
Or maybe you can provide some advice?
Example case:
I want to make a new observable each time after Just or other Observable creators emit a new value. In this case nice to unsubscribe from interval and create new observable
P.S Well, as I can see the flat map operator doesn't work too
output
The text was updated successfully, but these errors were encountered: