Build Your Own RxJS Pipeable Operators

Feels like magic.
It’s a beautiful feeling when technology works in mysterious, miraculous ways. So smooth! So effortless! So…
Wait, that’s not right. What’s it doing? I don’t get it. Help!
…until you encounter unexpected behavior. Good luck debugging magic.
To use technology to its fullest, you need to understand how it’s accomplishing the tasks set before it.
This course de-mystifies RxJS. It feels like magic, but it’s also one of the most laborious technologies to learn in front-end web development. We’ll open up the internals to take an up-close look at how RxJS handles Async programming so smoothly.
Over 12 lessons and 31 minutes, you'll get a handle on:
how RxJS pushes values from observables to subscribers, which take care of the output.
how operators handle all of the "in-between" operations where you can manipulate the values while they're still in-flight.
the internals of operators and subscribers and how to customize operators to your specific needs.

• Create a Generic Subscriber in RxJS
• Extend Subscriber to Override `_next` in RxJS
• Connect a Source to a Subscriber with RxJS `pipe`
• Use `lift` to Connect a `source` to a `subscriber` in RxJS
• Create a Reusable Operator from Scratch in RxJS
• Create Operators from Existing Operators in RxJS
• Implement the `map` Operator from Scratch in RxJS
• Chain RxJS Operators Together with a Custom `pipe` Function using Array.reduce
• Implement RxJS `mergeMap` through inner Observables to Subscribe and Pass Values Through
• Implement RxJS `switchMap` by Canceling Inner Subscriptions as Values are Passed Through
• Implement RxJS `concatMap` by Waiting for Inner Subscriptions to Complete
• `add` Inner Subscriptions to Outer Subscribers to `unsubscribe` in RxJS