This is RxJS v 4. Find the latest version here
Returns an observable sequence that terminates with an exception, using the specified scheduler to send out the single onError message.
exception
(Error): Error the observable sequence terminates with.[scheduler=Rx.Scheduler.immediate]
(Scheduler
): Scheduler to send the exceptional termination call on. If not specified, defaults to the immediate scheduler.
(Observable
): The observable sequence that terminates exceptionally with the specified exception object.
var source = Rx.Observable.return(42)
.selectMany(Rx.Observable.throw(new Error('error!')));
var subscription = source.subscribe(
function (x) {
console.log('Next: ' + x);
},
function (err) {
console.log('Error: ' + err);
},
function () {
console.log('Completed');
});
// => Error: Error: error!
File:
Dist:
Prerequisites:
NPM Packages:
NuGet Packages:
Unit Tests: