of
signature: of(...values, scheduler: Scheduler): Observable
Emit variable amount of values in a sequence.
Examples
Example 1: Emitting a sequence of numbers
//emits any number of provided values in sequence
const source = Rx.Observable.of(1, 2, 3, 4, 5);
//output: 1,2,3,4,5
const subscribe = source.subscribe(val => console.log(val));
Example 2: Emitting an object, array, and function
import { of } from 'rxjs/observable/of';
//emits values of any type
const source = of({ name: 'Brian' }, [1, 2, 3], function hello() {
return 'Hello';
});
//output: {name: 'Brian}, [1,2,3], function hello() { return 'Hello' }
const subscribe = source.subscribe(val => console.log(val));
Additional Resources
- of
- Official docs - Creation operators: of
- André Staltz
Source Code:
https://github.com/ReactiveX/rxjs/blob/master/src/internal/observable/of.ts