Starting a Stream with SwitchMap

Stopping a Stream with TakeUntil

Updating Data with Scan

Displaying Initial Data with StartWith

Changing Behavior with MapTo

Handling Multiple Streams with Merge

Refactoring Composable Streams in RxJS

Getting Input Text with Map

Combining Streams with CombineLatest

Adding Conditional Logic with Filter

Completing a Stream with TakeWhile

Handling a Complete Stream with Reduce

Logging a Stream with Do

Timer and Input Recap

Refactoring CombineLatest to WithLatestFrom

Resubscribing to a Stream with Repeat

Basic DOM Rendering with Subscribe

Sharing Streams with Share

Step-by-Step Async JavaScript with RxJS

When you need to total up everything that has happened in your stream, you need to a way to tell your stream that it is “done”. This lesson covers how to use `takeWhile` to complete a stream.

https://app.egghead.io/api/v1/lessons/rxjs-completing-a-stream-with-takewhile/subtitles

[00:00] As it stands right now, our game will run forever. Once I hit start, and start scoring points, it's never going to stop. It's going to keep on counting. You might think you add another filter or something to make it stop, but filter does not trigger a complete event on our stream. Filter just tells our stream which things to put through.

[00:19] What we want is something called takeWhile, which will look exactly like a filter, so we'll say data. If we want our game to end after three seconds, we can say data count is less than or equal to three. Then, when we start our game, you can see we can do one, two, three.

[00:39] It's never going to score any points for anything beyond that. We also never see when our game actually completes if you want to do something when it's done. What you do there is subscribe actually takes three functions. This is the function that gets called every onNext or every tick.

[00:56] This one would get called if there's an error, so log out the error if an error happens. The third function is one that gets called once your stream is complete, so just log out complete. If I start my stream, I type one, and then wait until three. I'll get a point for three. It completes. Then I can never score again because my stream is done.

Completing a Stream with TakeWhile

Share this video with your friends

Course

Step-by-Step Async JavaScript with RxJS