diff --git a/doc/api/subjects/subject.md b/doc/api/subjects/subject.md index 76279b10b..60b27edcb 100644 --- a/doc/api/subjects/subject.md +++ b/doc/api/subjects/subject.md @@ -22,15 +22,15 @@ var subscription = subject.subscribe( console.log('Completed'); }); -subject.onNext(42); +subject.next(42); // => Next: 42 -subject.onNext(56); +subject.next(56); // => Next: 56 -subject.onCompleted(); +subject.complete(); // => Completed ``` @@ -75,10 +75,10 @@ var subscription = subject.subscribe( console.log('Completed'); }); -subject.onNext(42); +subject.next(42); // => Next: 42 -subject.onCompleted(); +subject.complete(); // => Completed ``` @@ -126,11 +126,11 @@ var observer = Rx.Observer.create( var observable = Rx.Observable.create(function (obs) { worker.onmessage = function (data) { - obs.onNext(data); + obs.next(data); }; worker.onerror = function (err) { - obs.onError(err); + obs.error(err); }; return function () { @@ -151,7 +151,7 @@ var subscription = subject.subscribe( console.log('Completed'); }); -subject.onNext(42); +subject.next(42); // => Next: 42 ``` @@ -184,16 +184,16 @@ var subscription = subject.subscribe( console.log('Completed'); }); -subject.onNext(42); +subject.next(42); // => Next: 42 -subject.onCompleted(); +subject.complete(); // => Completed subject.dispose(); try { - subject.onNext(56); + subject.next(56); } catch (e) { console.log(e.message); }