rxjsが観測可能なタイムアウトのエラーを常に作成しました

Question

ok、だから今は本当に困惑しています。

const created = Rx.Observable.create(observer => { 
    observer.next(42) 
}) 
const ofd = Rx.Observable.of(42) 

const createSub = name => [ 
    val => console.log(`${name} received ${val}`), 
    error => console.log(`${name} threw ${error.constructor.name}`) 
] 

created 
    .timeout(100) 
    .subscribe(
    ...createSub('created') 
) 

ofd 
    .timeout(100) 
    .subscribe(
    ...createSub('ofd') 
) 

プリント

"created received 42" 
"ofd received 42" 
"created threw TimeoutError" 

次のコードを実行すると、私はなぜcreated観測誤差が、それは価値を発するが、ofd観察可能でないにもかかわらずない、全くこのことを理解していません？

RxJS 5を使用すると、jsbin.com 5.0.3と私のアプリケーション5.4.3で問題が発生します。

（注：これはあまりにも対象で発生し、この例を作成するために私を導いた）

Answer 1

Observable.of値が放出された直後のストリームを完了しています。

Observable.createは、観測可能な状態を維持します。それで、timeoutがエラーを投げているのです。

const created = Rx.Observable.create(observer => { 
    observer.next(42); 
    observer.complete(); 
}) 

では

const created = Rx.Observable.create(observer => { 
    observer.next(42) 
}) 

を交換し、エラーはもうありません。