Observable Streams

Functional reactive programming

Watch User Created Playlist (23)

This playlist is user created.

pro-course-rss-logo

PRO RSS Feed

Changing Behavior with MapTo

P

Starting a Stream with SwitchMap

Handling Multiple Streams with Merge

P

Refactoring CombineLatest to WithLatestFrom

P

Combining Streams with CombineLatest

P

Refactoring Composable Streams in RxJS

P

Completing a Stream with TakeWhile

P

Displaying Initial Data with StartWith

P

Stopping a Stream with TakeUntil

P

Resubscribing to a Stream with Repeat

P

Creation operators: interval and timer

P

Returning subscriptions from the subscribe function

P

Logging a Stream with Do

P

Toggle A Stream On And Off With RxJS

P

Introduction to the ConnectableObservable and using publish().refCount() in RxJS

P

Throttled Buffering in RxJS

P

Aggregating Streams With Reduce And Scan using RxJS

P

Event Delegation with RxJS

P

Reactive Programming - An overview of reactive concepts

P

Reacting to multiple inputs using RxJS's combineLatest

P

Creation operator: of()

P

Model-View-Intent pattern for separation of concerns

Sequelize: Validating Models

rx tutorial about Changing Behavior with MapTo

Changing Behavior with MapTo

2:32 rx PRO

You often need streams to trigger different behaviors on the data based on which streams triggers. This lessons shows how to use mapTo to pass functions into the scan operator and have completed control over you data.

rx tutorial about Starting a Stream with SwitchMap

Starting a Stream with SwitchMap

5:48 rx

As developers, we tend to carry over ideas from past experience and try to reapply them to something new. This lesson teaches you about why you should usually favor switchMap over subscribe and why thinking about subscribe as an event handler can lead to problems.

rx tutorial about Handling Multiple Streams with Merge

Handling Multiple Streams with Merge

2:59 rx PRO

You often need to handle multiple user interactions set to different streams. This lesson shows hows Observable.merge behaves like a "logical OR" to have your stream handle one interaction OR another.

rx tutorial about Refactoring CombineLatest to WithLatestFrom

Refactoring CombineLatest to WithLatestFrom

2:17 rx PRO

This lesson shows why it’s preferable to using withLatestFrom instead of combineLatest in certain scenarios.

rx tutorial about Combining Streams with CombineLatest

Combining Streams with CombineLatest

3:08 rx PRO

Two streams often need to work together to produce the values you’ll need. This lesson shows how to use an input stream and an interval stream together and push an object with both values through the stream.

rx tutorial about Refactoring Composable Streams in RxJS

Refactoring Composable Streams in RxJS

4:44 rx PRO

Refactoring streams in RxJS is mostly moving pieces of smaller streams around. This lessons demonstrates a simple refactoring by requiring the StopWatch to be more configurable.

rx tutorial about Completing a Stream with TakeWhile

Completing a Stream with TakeWhile

1:19 rx PRO

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.

rx tutorial about Displaying Initial Data with StartWith

Displaying Initial Data with StartWith

1:06 rx PRO

You often need to render out data before you stream begins from a click or another user interaction. This lessons shows how to use startWith to set the initial output before you trigger your stream.

rx tutorial about Stopping a Stream with TakeUntil

Stopping a Stream with TakeUntil

4:10 rx PRO

Observables often need to be stopped before they are completed. This lesson shows how to use takeUntil to stop a running timer. Then we use the starting stream and the stopping stream together to create a simple stopwatch.

rx tutorial about Resubscribing to a Stream with Repeat

Resubscribing to a Stream with Repeat

2:04 rx PRO

When you complete a stream, there’s no way to restart it, you must resubscribe. This lesson shows how repeat comes in handy to resubscribe after a stream has completed.

rx tutorial about Creation operators: interval and timer

Creation operators: interval and timer

4:11 rx PRO

It is quite common to need an Observable that ticks periodically, for instance every second or every 100 miliseconds. We will learn about operators interval() and timer(), both of which are similar to setInterval() in JavaScript.

rx tutorial about Returning subscriptions from the subscribe function

Returning subscriptions from the subscribe function

3:14 rx PRO

So far, when writing these subscribe functions, we haven't returned anything. It is possible return an unsubscribe function from a subscribe function. In this lesson we will see how to allow observers to subscribe and unsubscribe from an Observable.

rx tutorial about Logging a Stream with Do

Logging a Stream with Do

1:34 rx PRO

To help understand your stream, you’ll almost always want to log out some the intermediate values to see how it has progressed during its lifespan. This lesson teaches you how to use do to log values in the middle of the stream without having an impact on the rest of the stream.

rx tutorial about Toggle A Stream On And Off With RxJS

Toggle A Stream On And Off With RxJS

3:52 rx PRO

This lesson covers how to toggle an observable on and off from another observable by showing how to use a checkbox as a toggle for a stream of data.

rx tutorial about Introduction to the ConnectableObservable and using publish().refCount() in RxJS

Introduction to the ConnectableObservable and using publish().refCount() in RxJS

3:56 rx PRO

An RxJS cold Observable can be made hot by declaring it with .publish().refCount(). What does publish() do? What does refCount() do? This lesson introduces the ConnectableObservable, and how to use it with publish and refCount.

rx tutorial about Throttled Buffering in RxJS

Throttled Buffering in RxJS

3:41 rx PRO

Capturing every event can get chatty. Batching events with a throttled buffer in RxJS lets you capture all of those events and use them responsibly without overloading a subscriber downstream.

rx tutorial about Aggregating Streams With Reduce And Scan using RxJS

Aggregating Streams With Reduce And Scan using RxJS

3:47 rx PRO

What is the RxJS equivalent of Array reduce? What if I want to emit my reduced or aggregated value at each event? This brief tutorial covers Observable operators reduce() and scan(), their differences and gotchas.

rx tutorial about Event Delegation with RxJS

Event Delegation with RxJS

6:17 rx PRO

Event delegation is an extremely powerful technique. It allows you to use a single event handler to listen to events on any number of child elements. It also has the added benefit of working with dynamically added elements without even a single line of additional code. Libraries such as jQuery offer this feature right out of the box, but with RxJS and the fromEvent helper, we’ll need to utilise the selector function to achieve the same result. NOTE: The element.closest method shown in this video required a polyfill for older version of IE which can be found here https://github.com/jonathantneal/closest

rx tutorial about Reactive Programming - An overview of reactive concepts

Reactive Programming - An overview of reactive concepts

2:14 rx PRO

This video gives an overview of the concepts of reactive programming we saw during this series, and explains how reactive programming can provide true separation of concerns.

rx tutorial about Reacting to multiple inputs using RxJS's combineLatest

Reacting to multiple inputs using RxJS's combineLatest

7:36 rx PRO

There are certain situations in which you’ll want access to the latest values from multiple Observables whenever any one of them produces a value. This is exactly what combineLatest was designed for, and in this lesson we’ll use it to build up an image url that requires values from 3 different inputs - triggered every time any one of them change.

rx tutorial about Creation operator: of()

Creation operator: of()

2:06 rx PRO

RxJS is a lot about the so-called "operators". We will learn most of the important operators, one by one. In this lesson, we will see our first creation operator: of().

rx tutorial about Model-View-Intent pattern for separation of concerns

Model-View-Intent pattern for separation of concerns

3:17 rx

We built the BMI calculator all inside one function: main(). As apps scale, we don't want main() to grow. We need an organized pattern where each function focuses on doing one thing. This lesson shows how we can easily refactor the main() function into three parts: Intent, Model, and View.

node tutorial about Sequelize: Validating Models

Sequelize: Validating Models

3:24 node

The Node.js ORM, Sequelize, has a powerful system for validating both models and individual columns. This video covers a handful of the more than 30 built-in validators, as well as writing custom validators from scratch.

HEY, QUICK QUESTION!
Joel's Head
Why are we asking?