A small example of using RxJs.
Here we create an observable with of
, we then use pipe
to take the values (here just "true") into a flow.
Using delay
operator to wait for a number of ms. The tap
operator lets us "tap into" a stream and "do something".
We log some information, and repeat that pattern 3 times, after which the stream ends.
To start the pattern we use subscribe
and after the flow has ended we unsubscribe
to the observable stream.
Top comments (0)