将数据添加到ConnectableObservable

Question

如何将数据放入ConnectableObservable？我问这是一个可观察的数据不可用，直到一个异步函数完成的情况。一个简单的例子：

function myFunc() { 
    let observable = Rx.Observable.create().publish(); 
    setTimeout(() => console.info('TIMEOUT') || observable.of('data').connect(), 300); 
    return observable; 
} 

myFunc().subscribe(x => console.log(x)); 

我也曾尝试

observable.map(() => 'data').connect() 
observable.flatMap(() => Observable.of('data')).connect() 

在我的例子中没有成功替代.of()。

Answer 1

Observables does not have the connect() method。唯一的例外是ConnectableObservable，例如由publish()运算符返回。

例如，您可以执行以下操作：

let source = Observable.create(observer => { 
    const timer = setTimeout(() => observer.next('data'), 300); 

    return() => { 
     clearTimeout(timer); 
    }; 
}).publish(); 

source.connect(); 
source.subscribe(console.log); 

编辑：

let observable = Rx.Observable.create(...) 
    .publish(); 

let o1 = observable 
    .map(val => true) 
    .flatMap(...) 
    .subscribe(...); 

observable.connect(); 

......或者......

let observable = Rx.Observable.create(...); 
let o1 = observable 
    .map(val => true) 
    .flatMap(...) 
    .publish(); 

o1.subscribe(...); 
o1.connect();