Closed xuelink closed 8 years ago
AsyncSubject Constructor
in the example source should be subject
source
subject
var subject = new Rx.AsyncSubject(); subject.onNext(42); subject.onCompleted(); var subscription = source.subscribe( function (x) { console.log('Next: ' + x); }, function (err) { console.log('Error: ' + err); }, function () { console.log('Completed'); }); // => 42 // => Completed
@behicsakar welcome to PR
AsyncSubject Constructor
in the example
source
should besubject