RxJS Playground
A blank canvas to play / experiment with RxJS: https://github.com/Reactive-Extensions/RxJS
by skeemer
HTML
<script src="https://unpkg.com/rxjs/bundles/rxjs.umd.min.js"></script>JavaScript
const { Observable, Subject, ReplaySubject, from, of, range } = rxjs;
const { map, filter, switchMap } = rxjs.operators;
console.clear();
/* var o1 = Observable.range(1, 1).delay(2500);
var o2 = Observable.range(2, 1).delay(3500);
o1.subscribe(x => console.log('x:', x));
o2.subscribe(y => console.log('y:', y));
o2.combineLatest(o1).subscribe((a) => console.log('a', a));
o1.combineLatest(o2).subscribe((b) => console.log('b', b));
*/
var subject = new Subject();
subject.next(true);
subject.complete(true);
subject.asObservable().subscribe(() => console.log('next'), () => console.log('error'),() => console.log('complete'));
(new Observable((observer) => observer.next(true))).subscribe(() => console.log('next'), () => console.log('error'),() => console.log('complete'));
/* subject.subscribe({
next: (v) => console.log('observerA: ' + v)
} );/*
/* subject.subscribe({
next: (v) => console.log('observerB: ' + v)
});
*/
var observable = from([1, 2, 3]);
var observable2 = from([4, 5, 6]);
//observable.subscribe(subject);
//observable2.subscribe(subject);