我正在尝试将发出的值乘以 10 以使结果流为：10、20、30 ... 但是在 map 方法中我不能将它相乘，因为编译器会抛出错误。
const numbers$ = Observable.interval(1000);
numbers$.pipe(
map((x) => 10 * x)
);
地图线错误：
The right-hand side of an arithmetic operation must be of type 'any', 'number' or an enum type.
我还检查了 x 是“数字”的类型；
我哪里错了？
/编辑
来自 Inge Olaisen 的评论
我将代码更改为：
map((x) => 10 + +x) 并且工作正常
我可以假设它是编译器错误，因为它不能将 x 识别为数字吗？
【问题讨论】：
标签： javascript angular rxjs observable
常量数$ = Observable.interval(1000); numbers$.pipe(takeUntil(this.unsubscribe)).subscribe((x) => 10 * x);
也就是说编译器抱怨有点奇怪，但您可以尝试： const numbers$: Observable = Observable.interval(1000);
unsubscribe 是一个在 ngOnDestroy() 方法中调用 .next() 和 .complete() 的主题。
如果要将数据从一种类型映射到另一种类型，则使用映射。通常，如果您有数据并将其转换为另一个 observable，则该数据又会以某种形式在 html 中订阅或使用它。
如果你只是想使用你得到的数据，那么你把它放入订阅中。
【讨论】：
const numbers$: Observable<number> = Observable.interval(1000); 获得相同的结果。就我而言，我想了解为什么这段代码没有按预期工作
//emit value in sequence every 1 second
const source = interval(1000);
//output: 0,1,2,3,4,5....
const subscribe = source.subscribe(val => console.log(val));
连同映射当前值：
//emit value in sequence every 1 second
const source = interval(1000);
//output: 0,1,2,3,4,5....
const subscribe = source
.pipe(map(n => 10 * n))
.subscribe(val => console.log(val));
我想补充一点，您应该管理您的 observables 的处置，这里有一个 good article 用于处置/取消订阅 observables。
【讨论】：