rxjs：forkJoinは完了するために少なくとも1つの呼び出しを必要としますか？

Question

私はforkJoinしたい2つの観測があります。これらの観測の

var goodObservable = Rx.Observable.create(function(observer){ 
    observer.next('something'); 
    observer.complete(); 
    }); 

    var badObservable = Rx.Observable.create(function(observer){ 
    observer.complete(); 
    }); 


    var forkJoinedObservable = Rx.Observable.forkJoin([goodObservable, badObservable]); 

    forkJoinedObservable.subscribe(function(results){ 
    console.log(results); 
    }); 

一つは、唯一の完全な呼び出します。今私は、forkJoined observablesが決して起動されないことを発見しました。 forkJoinのサブスクリプションを実行させるには、badObservableのobserver.next（）をコールする必要があります。 [「何か」]

が、これはバグですか、私が正しく概念を理解していなかった。

私の予想される動作はforkJoin-購読はただ一つのアイテムを含む配列で実行されるだろうということでしょうか？

私はこのためplunkrを行った：https://plnkr.co/edit/QaA9DwyWAmTGbthvguPK?p=preview

Answer 1

forkJoin()各観察から放出された最後のアイテムを発します。この場合、放出する項目はないので、演算子は放出しません。

現実的な解決策は、それぞれの観察可能な部分に.startsWith(defaultValue)を呼び出すことです。forkJoin()も同様に完了できます。

var goodObservable = Rx.Observable.create(function(observer){ 
    observer.next('something'); 
    observer.complete(); 
}); 

var badObservable = Rx.Observable.create(function(observer){ 
    observer.complete(); 
}).startWith(null); 


var forkJoinedObservable = Rx.Observable.forkJoin([goodObservable, badObservable]); 

forkJoinedObservable.subscribe(function(results){ 
    console.log(results); 
}); 

放出した観測値だけの値を放出することについては、どの観測値が放出されたのかわからないため、これは機能しません。もちろん、それはnullを放出した可能性があります。しかし、これは演算子を組み合わせることで実現可能ですが、変化するとは思いません。