Gain insights into reactive programming with RxJS. Learn about observables, operators, and concurrent programming to create real-world applications like a real-time earthquake visualizer and spaceship game.

_ Reactive Programming with RxJS by The Pragmatic Programmer_ .png

data.tar.gz

test rx

rx live

rx live-copy

rx live-earth

cycle

test rx-copy

cycle-rx

rx-cycle

test rx-copy-copy

cycle-rx-copy

cycle-rx-copymaham

qunit-job

In this course, you will learn about reactive programming techniques and use them to create real-world applications. Throughout this course, you will learn important concepts of RxJS programming such as observables, operators, concurrent programming, and how to build a complete web application.

Additionally, you will have the opportunity to build out applications for different real-world scenarios so that you can put what you learn into practice. You will use RxJS operators in scenarios such as the real-time earthquake visualizer and the reactive spaceship game.

By the end, you will have a new skill that you can utilize to build reactive programs as well as a few new projects to add to your portfolio.

Reactive Programming with RxJS

A string of variables in a specific range

What type of Observable does a range operator emit?

What type of Observable does a range operator emit?

Which transformation operator takes an Observable and a function and applies that function to each of the values in the source Observable?

Which transformation operator takes an Observable and a function and applies that function to each of the values in the source Observable?

```
var isEven = (function(val) 
{ return val % 2 === 0; });
var src = [1, 2, 3, 4, 5];
var even = src.filter(isEven);
even.forEach(logValue);
```

```
var isEven = (function(val) 
{ return val % 2 === 0; });
var src = Rx.Observable.range(1, 5); 
var even = src.filter(isEven);
even.subscribe(logValue);
```

Which of the following is the correct implementation of the `filter` operator using Observables?

Which of the following is the correct implementation of the <code>filter</code> operator using Observables?

Which of the following is the base implementation for a whole subset of methods called aggregate operators?

Which of the following is the base implementation for a whole subset of methods called aggregate operators?

What do aggregate operators return after processing a sequence?

What do aggregate operators return after processing a sequence?

Which of the following emits each intermediate result?


Which of the following emits each intermediate result?

`concatAll` is a function that takes an array of arrays and returns a flattened single array while `flatMap` does the same thing, but it flattens Observables instead of arrays.

`concatAll` is a function that takes an array of arrays and returns a flattened Observable while `flatMap` flatten arrays.

`concatAll` takes Observables and flattens arrays, while `flatMap` flattens Observables.

Which of the following is correct?

makes the subscription start receiving notifications from Observables

makes the subscription stop receiving notifications from Observables

allows the subscription to continue receiving notifications from Observables

The `dispose` method of an Observables disposable ______.

The <code>dispose</code> method of an Observables disposable ______.

Implicit sequence cancellation is done by:

Implicit sequence cancellation is done by:

Whenever an error occurs, the Observable stops emitting items, and `onCompleted` is not called.

Whenever an error occurs, the Observable starts emitting items, and `onCompleted` is called.


Whenever an error occurs, the Observable stops emitting items, and `onCompleted` is called.

What is the default behavior of `onError`?

What is the default behavior of <code>onError</code>?

Which of the following is used to react to errors in a sequence?

Which of the following is used to react to errors in a sequence?

**(True or False)** The `retry` operator will always retry the whole Observable sequence again.

(True or False) The <code>retry</code> operator will always retry the whole Observable sequence again.

Getting Started

Introduction to Reactive Programming with RxJS

Understanding the Reactiveness

Understanding the Observables

Understanding Sequencing and its Operators

Make a Real-time Earthquake Visualizer

Building Concurrent Programs Through Pipelines

RxJS Subject Class

Building a Reactive Spaceship to Keep the Application Pure

Building a Complete Web Application Using RxJS

Getting Real Time Updates from Twitter using Node.js

Schedulers

React Web Applications With Cycle.js and using Model View Intent

Closing Remarks

Quiz Yourself on Sequences