我有一个可观察的A和另一个可观察的B(这是一个行为主体).我需要B像信号量一样工作，当我得到a中的值变化时，如果B为真，a执行一些逻辑，否则等待B的需要变为真.我try 了不同的方法，但没有成功..
类似于在C中使用sem\u wait for waiting 0 value
A
.pipe(
mergeMap(aval => B.filter(f => f))
// Here i need to wait B to become true
)
.subscribe(v => dosomething)
谢谢大家！
判断这个.当B event变为true时，下面的代码将调用每个A event(如果您一次只想要一个A event，只需将mergeMap操作符更改为switchMap，如果您想要保留正确的顺序，则将其更改为concatMap，并将dosomething移到take(1)行下方的tap操作符)
A.pipe(
mergeMap(aval => B.pipe(
filter(f => f),
map(()=> aval),
take(1) // you need to unsubscribe the inner observable
)
)
)
.subscribe(v => dosomething)