Rx.Observer.fromNotifier(handler)

Creates an observer from a notification callback.

参数

1. handler (Function): Function that handles a notification.

返回值

(Observer): The observer object that invokes the specified handler using a notification corresponding to each message it receives.

Example

function handler(n) {
    // Handle next calls
    if (n.kind === 'N') {
        console.log('Next: ' + n.value);
    }

    // Handle error calls
    if (n.kind === 'E') {
        console.log('Error: ' + n.exception);
    }

    // Handle completed
    if (n.kind === 'C') {
        console.log('Completed');
    }
}

Rx.Observer.fromNotifier(handler).onNext(42);
// => Next: 42

Rx.Observer.fromNotifier(handler).onError(new Error('error!!!'));
// => Error: Error: error!!!

Rx.Observer.fromNotifier(handler).onCompleted();
// => false