条件が満たされるまでストリーム上のイベントを無視しますか？

Question

ボタンクリックイベントからストリームを作成しました。このボタンは、データベース上の作成アクションに対応します。明らかに、私はデータベースアクションを1回だけ起動させたい（少なくとも完了するまで）。 Api.createが返されるまで、createButtonStreamのイベントを無視する方法はありますか？すなわち、最初のイベントは＃Api.createを呼び出す必要があり、後続のイベントは＃Api.createが復帰するまで無視されるべきです。

createButtonStream 
    .flatMap(() => Api.create()) //Needs to fire once until doSomething() is called 
    .onValue(result => doSomething(result)) 

頭に浮かぶ唯一の方法は、グローバルな状態を使用することです...と私はむしろそれをしないと思います。

//i don't wanna do this 
let condition = true 

createButtonStream 
    .filter(() => condition) 
    .map(() => condition = false) 
    .flatMap(() => Api.create()) 
    .onValue(result => {condition = true; doSomething(result)}) 

Answer 1

awaitingを使用できます。鶏と卵の問題を回避するにはバスが必要です。 RxJSで

const filterBus = new Bacon.Bus() 

const createDone = createButtonStream 
    .filter(filterBus.toProperty(true)) 
    .flatMap(() => Api.create()) 

const inProgress = createButtonStream.awaiting(createDone) 
filterBus.plug(inProgress.not()) 

createDone.onValue(doSomething) 

Answer 2

（RxJSを使用している場合5）あなたは

createButtonStream 
    .flatMapFirst(() => Api.create())  
    .subscribe(result => doSomething(result)); 

flatMapFirstは黙って最初のソースが完了する前に、彼らが到着した場合、メソッドが呼び出されませすべきイベントをドロップしますflatMapFirstかexhaustMap演算子を使用します。