RxJS教程

对于mergeMap运算符，将对每个源值应用一个项目函数，并将其输出与输出Observable合并。 语法 mergeMap(project_func: function): Ob…

每当源Observable发出一个值时，就将常量值与Observable一起输出。 语法 mapTo(value: any): Observable 参量 value &#8211…

对于map运算符，将项目函数应用于源Observable上的每个值，并将相同的输出作为Observable发出。 语法 map(project_func: function): O…

在groupBy运算符中，根据特定条件对输出进行分组，并且将这些分组项作为GroupedObservable发出。 语法 groupBy(keySelector_func: (va…

expand运算符接受一个函数作为参数，该函数以递归方式应用于源可观察的对象，也应用于输出可观察的对象。最终值是可观察的。 语法 expand(recursive_func:obs…

该运算符将以数组形式给出值，它将一个参数作为函数来决定何时关闭，发出和重置buffer。 语法 bufferWhen(closing_func: Observable): Obse…

在bufferToggle的情况下，它需要2个参数，openings和CloseingSelector。开始参数是可订阅的或承诺启动缓冲区的，而第二个参数CloseingSelec…

这类似于bufferCount，因此在这里，它将从调用它的可观察对象中收集值，并发出bufferTimeSpan完成。它接受1个参数，即bufferTimeSpan。 语法 buf…

对于buffercount运算符，它将从调用它的可观察对象收集值，并在给buffercount的缓冲区大小匹配时发出相同的值。它使用2个参数buffersize，第二个参数是sta…

缓冲区对可观察对象进行操作，并将参数作为可观察对象。它将开始对数组中其原始可观察对象发出的值进行缓冲，并在将可观察对象作为参数发出时发出相同的值。一旦将作为对象的observabl…

它将返回一个可观察到的对象，该对象将是第一个可观察到的源的镜像副本。 语法 race(observables: array[]): Observable 参量 observable…

该运算符将输入可观察的输入，并将发出可观察的所有值，并发出一个可观察的输出。 语法 merge(observable:array[]): Observable 参量 observa…

此运算符将接受数组或dict对象作为输入，并将等待可观察对象完成并返回从给定可观察对象发出的最后一个值。 语法 forkJoin(value: array or dict obje…

该运算符将顺序地发出给定的Observable作为输入，然后进行下一个。 语法 concat(observables: Array): Observable 参量 observab…

在reduce运算符中，累加器函数用于可观察的输入，并且累加器函数将以可观察的形式返回累加值，并将可选的种子值传递给累加器函数。 reduce()函数将接受两个参数，一个是累加器函…

min()方法将使用所有值的可观察值，并返回具有最小值的可观察值。它以比较函数作为参数，这是可选的。 语法 min(comparer_func?: number): Observa…

max()方法将使用所有值的可观察值，并返回具有最大值的可观察值。它以比较函数作为参数，这是可选的。 语法 max(comparer_func?: number): Observa…

count（）接收带有值的Observable，并将其转换为将提供单个值的Observable。count函数将谓词函数作为可选参数。该函数的类型为boolean，仅当值是true…

该运算符将决定要订阅哪个Observable。 语法 iif(condition: Function):Observable 参量 condition-条件是一个函数，如果其返回t…

该运算符将创建一个可观察对象，该对象将在超时后发出该值，并且该值将在每次调用后保持递增。 语法 timer(dueTime: number | Date): Observable …