当我仅使用订阅方法时，它的工作原理是正确的，但是使用此代码-我不明白结果。
const Observable = require("rxjs").Observable;
let i = 0;
const x = new Observable((o) => {
setInterval(() => o.next(++i), 1000);
});
(async () => {
while (true) {
try {
console.log("loop");
console.log("value", await x.toPromise());
} catch (e) {
console.log(e);
}
}
})();
x.subscribe((value) => {
console.log("subscribe", value);
});
此代码结果是：
loop
subscribe 2
subscribe 4
subscribe 6
subscribe 8
subscribe 10
subscribe 12
subscribe 14
发生了什么？
它与使用toPromise的变体相同
function a() {
x.toPromise().then((value) => {
console.log("promise", value);
a();
}).catch((e) => {
console.log("error", value);
});
}
a();
toPromise()在Observable完成时执行。由于您的可观察对象从未真正完成，因此不会执行。使用take(1)强制它可观察完成之前发出的价值。
const Observable = require("rxjs").Observable;
let i = 0;
const x = new Observable((o) => {
setInterval(() => o.next(++i), 1000);
});
(async () => {
while (true) {
try {
console.log("loop");
console.log("value", await x.take(1).toPromise());//here
} catch (e) {
console.log(e);
}
}
})();
x.subscribe((value) => {
console.log("subscribe", value);
});
输出：
loop
subscribe 2
value 1
loop
subscribe 4
value 5
loop
subscribe 7
value 9
loop
subscribe 11
value 14
至于值：
take()一旦发出至少一个值，它将完成，无论源可观察项是否完成。因此，这实际上取决于下一次toPromise()调用该可观察值时发出的值
本文收集自互联网，转载请注明来源。
如有侵权，请联系 [email protected] 删除。
我来说两句