When you are starting out or you just want to test something you tend to start out with the create()
operator. This takes a function with an observer
as a parameter. This has been mentioned in previous sections such as Observable Wrapping. The siignature looks like the following
Observable.create([fn])
And an example looks like:
import { Observable } from 'rxjs';
Observable.create(observer => {
observer.next( 1 );
})
Signature
import { range } from 'rxjs';
range([start],[count])
Example
import { range } from 'rxjs';
let stream$ = range(1,3)
// emits 1,2,3