可观察到的,通过数值循环的

我有两个被压缩的观测点。一个从外部源生成事件流,另一个生成预定义字符串流。

示例代码:

import { interval, of, zip } from "rxjs";
import { pipe, mapTo } from "rxjs/operators";

let ticks$ = interval(1000).pipe(mapTo("Tick"));
let words$ = of("foo", "bar"); 

let ticker$ = zip(ticks$, words$);

ticker$.subscribe((e) => console.log(e));

words$ ticker$

#=> ["Tick", "foo"]
#=> ["Tick", "bar"]

到目前为止,一切顺利。它根据以下文件工作: #of

现在,我想 言语$ 要骑自行车。也就是说,当发射最后一个元素时,它将从开始处重新开始。所以 股票行情$ 不会停止:

#=> ["Tick", "foo"]
#=> ["Tick", "bar"]
#=> ["Tick", "foo"]
#=> ...

查看文档,没有 #cycle 创建者功能。