Search⌘ K
AI Features
Home
Courses
Reactive Programming with RxJS

Creating Observables and Operators

Explore how to create Observables using the create operator in RxJS and understand the role of Observers with methods like onNext, onCompleted, and onError. Learn how to manage data streaming, completion signals, and error handling in reactive programming.

We'll cover the following...

There are several ways to create Observables, the create operator being the most obvious one. The create operator in the Rx.Observable object takes a callback that accepts an Observer as a parameter. This function defines how the Observable will emit values. Here’s how we create a simple Observable:

Javascript (babel-node)
var observable = Rx.Observable.create(function(observer) 
{ 
    observer.onNext('Simon');
    observer.onNext('Jen');
    observer.onNext('Sergi');
    observer.onCompleted(); // We are done 
});

When we subscribe to this Observable, it emits three strings by calling the onNext method on its listeners. It ...