forkJoin（）void関数はどうですか？例えば

Question

私は、私はしかし、これがすべてで働いて、その方法が、ボイドの機能をキャストするためにされていない

Observable.forkJoin([voidFunction1(), voidFunction2()]).subscribe() ; 

にvoidFucntion1()、voidFunction2()たいか？元のvoidFunction（）を変更することなく？

Answer 1

まず： I 非常にがそれ以外、あなたはあなたのボイドの機能をリファクタリングないことを示唆している、それはそれがを行っていても、ストリーム内の空隙の機能を使用することが可能に一種でありますまったく意味ない：

Rx.Observable.defer(() => { 
 
    voidFunction1(); 
 
    voidFunction1(); 
 
    return Rx.Observable.of("Done"); 
 
}) 
 
.subscribe(console.log); 
 

 
function voidFunction1() { 
 
    console.log("Called VoidFunc"); 
 
    // I'm not enjoyed 
 
    // because I'm void! 
 
}

<script src="https://unpkg.com/rxjs/bundles/Rx.min.js"></script>

：

あなたはrxjsにおけるボイドの機能を行うことができる唯一のことは、do演算子はとdefer演算子はあり

---

は、使用するforkJoin持っ場合： `forkJoin`あなたの機能を使用するために

const voidWrapper$ = wrapVoid(voidFunc); 
 
const voidWrapper2$ = wrapVoid(voidFunc); 
 

 
Rx.Observable.forkJoin(voidWrapper$, voidWrapper2$) 
 
.subscribe(console.log); 
 

 

 
function wrapVoid(func) { 
 
    return Rx.Observable.defer(() => { 
 
    func(); 
 
    return Rx.Observable.of("Done"); 
 
    }) 
 
} 
 

 
function voidFunc() { 
 
    console.log("called voidFunc"); 
 
    // notn' ho! 
 
}

<script src="https://unpkg.com/rxjs/bundles/Rx.min.js"></script>

Answer 2

フォークジョインは、コールバック関数を実行する前にすべてのオブザーバブルが解決するまで待機します。

帰ってこない「void」観測結果があれば、forkjoinはハングします。何かを "返す"ことがなくても、それらの関数に解決策を持たせる必要があります。すべての