ββββ
Example 1: Observable that emits multiple values
( StackBlitz | jsBin | jsFiddle )
// RxJS v6+import { Observable } from 'rxjs';/*Create an observable that emits 'Hello' and 'World' onsubscription.*/const hello = Observable.create(function(observer) {observer.next('Hello');observer.next('World');observer.complete();});β//output: 'Hello'...'World'const subscribe = hello.subscribe(val => console.log(val));
Example 2: Observable that emits even numbers on timer
( StackBlitz | jsBin | jsFiddle )
// RxJS v6+import { Observable } from 'rxjs';β/*Increment value every 1s, emit even numbers.*/const evenNumbers = Observable.create(function(observer) {let value = 0;const interval = setInterval(() => {if (value % 2 === 0) {observer.next(value);}value++;}, 1000);βreturn () => clearInterval(interval);});//output: 0...2...4...6...8const subscribe = evenNumbers.subscribe(val => console.log(val));//unsubscribe after 10 secondssetTimeout(() => {subscribe.unsubscribe();}, 10000);
βcreateβ
π° - Official docs
βCreation operators: Create()β
π₯ π΅ - AndrΓ© Staltz
βUsing Observable.create for fine-grained controlβ
π₯ π΅ - Shane Osbourne
π Source Code: https://github.com/ReactiveX/rxjs/blob/master/src/internal/observable/GenerateObservable.tsβ