Operators construction

create

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

Rx.Observable.create([fn])

And an example looks like:

Rx.Observable.create(observer => {
    observer.next( 1 );
})

range

Signature

Rx.Observable.range([start],[count])

Example

let stream$ = Rx.Observable.range(1,3)

// emits 1,2,3

results matching ""

    No results matching ""