您需要的是某种主题。
ReplaySubject，
BehaviorSubject，
Subject，等。
创建一个主题，然后可以
subject.subscribe(...)订阅它。您也
subject.onNext(...)可以添加到流中。
例如：
var subject = new Rx.Subject();var subscription = subject.subscribe( function (x) { console.log('onNext: ' + x); }, function (e) { console.log('onError: ' + e.message); }, function () { console.log('onCompleted'); });subject.onNext(1);// => onNext: 1subject.onNext(2);// => onNext: 2subject.onCompleted();// => onCompletedsubscription.dispose();一个更具体的用例（每次成功返回HTTP响应时，都会添加到可观察的流中）：
var httpResponseStream = new Rx.Subject();var subscription = httpResponseStream.subscribe(function (response) { console.log('HTTP response success: ', response); });makeAJAXCall().then(function (response) { httpResponseStream.onNext(response);});正如另一位用户所说，如果您使用的是V5 ，请确保将所有设置都更改
onNext为
next。如果您使用的是V4，请坚持
onNext。
