我试图让 RxJs 在我的流中循环一个 Observable 直到它处于特定状态,然后让流继续。具体来说,我正在将同步 do/while 循环转换为 RxJs,但我假设同样的答案也可以用于 for 或 while 循环。
我以为我可以为此使用 doWhile(),但似乎条件函数无法访问流中的项目,这似乎违背了我的目的。
我不完全确定正确的响应式术语是什么,但这是我想要的示例:
var source = new Rx.Observable.of({val: 0, counter: 3});
source.map(o => {
o.counter--;
console.log('Counter: ' + o.counter);
if (!o.counter) {
o.val = "YESS!";
}
return o;
})
.doWhile(o => {
return o.counter > 0;
})
.subscribe(
function (x) {
console.log('Next: ' + x.val);
},
function (err) {
console.log('Error: ' + err);
},
function () {
console.log('Completed');
});
预期的输出是:
Counter: 3
Counter: 2
Counter: 1
Counter: 0
Next: YESS!
Completed
假设这是一个可以解决的问题,我不清楚您如何标记循环时要返回的位置的“开始”。
最佳答案
有 expand运算符通过允许您递归调用选择器函数来让您接近。在这种情况下,返回一个空的可观察对象将是你的休息。参见 jsbin :
var source = Rx.Observable.return({val: 0, counter: 3})
.expand(value => {
if(!value.counter) return Rx.Observable.empty();
value.counter -= 1;
if(!value.counter) value.val = 'YESS';
return Rx.Observable.return(value)
})
.subscribe(value => console.log(value.counter ?
'Counter: ' + value.counter :
'Next: ' + value.val));
关于javascript - RxJs:如何根据可观察对象的状态进行循环?,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/34246398/