码迷,mamicode.com
首页 > Web开发 > 详细

[RxJS] Subject basic

时间:2016-08-15 20:44:22      阅读:175      评论:0      收藏:0      [点我收藏+]

标签:

A Subject is a type that implements both Observer and Observable types. As an Observer, it can subscribe to Observables, and as an Observable it can produce values and have Observersw subscribe it.

First time I read 

 implements both Observer and Observable types

I was quite confused. 

 

As a Observable:

var subject = new Rx.Subject();
var subscription = subject.subscribe(
   function onNext(x) { console.log(onNext:  + x); },
   function onError(e) { console.log(onError:  + e.message); },
   function onCompleted() { console.log(onCompleted); }
);
subject.onNext(Our message #1);
subject.onNext(Our message #2);

/*
"onNext: Our message #1"
"onNext: Our message #2"
*/

Every time we call onNext() message to yield the value.

 

As a Observer, so we use ‘source‘ to sebscribe ‘subject‘, then subscribe ‘subject‘ again to get the side effect

var subject = new Rx.Subject();
var source = Rx.Observable.interval(300)
   .map(function(v) { return Interval message # + v; })
   .take(5);
source.subscribe(subject);
var subscription = subject.subscribe(
   function onNext(x) { console.log(onNext:  + x); },
   function onError(e) { console.log(onError:  + e.message); },
   function onCompleted() { console.log(onCompleted); }
);
setTimeout(function() {
   subject.onCompleted();
}, 1000);

/*
"onNext: Interval message #0"
"onNext: Interval message #1"
"onNext: Interval message #2"
"onCompleted"
*/

[RxJS] Subject basic

标签:

原文地址:http://www.cnblogs.com/Answer1215/p/5774175.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!