Игнорировать события в потоке, пока условие не будет удовлетворено?

Question

Я создал поток из событий нажатия кнопок. Кнопка соответствует действию create в базе данных. Очевидно, что я хочу, чтобы действие базы данных срабатывало только один раз (по крайней мере, пока оно не завершится). Есть ли способ игнорировать события на createButtonStream до Api.create? то есть первое событие должно вызывать # 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. Вам нужен автобус, чтобы обойти проблему с курицей и яйцом.

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 используется оператор flatMapFirst или exhaustMap (при использовании RxJS 5)

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

flatMapFirst молча уронить события, если они прибывают до завершения первого источника, метод не должен получить вызывается.