create

Creates an observer from the specified onNext, onError, and onCompleted actions.

Arguments

1. [onNext] (Function): Observer's onNext action implementation.

2. [onError] (Function): Observer's onError action implementation.

3. [onCompleted] (Function): Observer's onCompleted action implementation.

Returns

(Observer): The observer object implemented using the given actions.

Example

var source = Rx.Observable.return(42);

var observer = Rx.Observer.create(
  x => console.log(`onNext: ${x}`),
  e => console.log(`onError: ${e}`),
  () => console.log('onCompleted'));

var subscription = source.subscribe(observer);

// => onNext: 42
// => onCompleted

Example