RxJS multicast

2020-10-13 10:23 更新

返回一个Observable,该对象发出对共享基础底层流的单个预订的ConnectableObservable发出的项目调用指定选择器的结果。

multicast<T, R>(subjectOrSubjectFactory: Subject<T> | (() => Subject<T>), selector?: (source: Observable<T>) => Observable<R>): OperatorFunction<T, R>

参量

subjectOrSubjectFactory 工厂函数创建一个中间主题,通过该主题,源序列的元素将被多播到选择器函数或主题,以将源元素推入其中。
选择器 可选的。 默认值为 undefined。  可选的选择器功能,可以根据需要多次使用多播的源流,而不会导致对该源流的多次订阅。给定来源的订阅者将从订阅开始就接收该来源的所有通知。

returns

OperatorFunction<T, R>:一个Observable,它发出对选择器调用的结果,该选择器由ConnectableObservable共享单个订阅到基础流的a发出的项目组成。

描述

multicast marble diagram

超载

multicast(subject: Subject<T>): UnaryFunction<Observable<T>, ConnectableObservable<T>>

参量 类型
学科 类型: Subject

returns UnaryFunction<Observable<T>,ConnectableObservable<T>>

multicast(subject: Subject<T>, selector: (shared: Observable<T>) => O): UnaryFunction<Observable<T>, ConnectableObservable<ObservedValueOf<O>>>

参量 类型
学科 类型: Subject
选择器 类型: (shared: Observable) => O

returns UnaryFunction<Observable<T>, ConnectableObservable<ObservedValueOf<O>>>

multicast(subjectFactory: (this: Observable<T>) => Subject<T>): UnaryFunction<Observable<T>, ConnectableObservable<T>>

参量 类型
subjectFactory 类型: (this: Observable) => Subject

returns UnaryFunction<Observable<T>, ConnectableObservable<T>>

multicast(SubjectFactory: (this: Observable<T>) => Subject<T>, selector: (shared: Observable<T>) => O): OperatorFunction<T, ObservedValueOf<O>>

参量 类型
SubjectFactory 类型: (this: Observable) => Subject
选择器 类型: (shared: Observable) => O

returns OperatorFunction<T, ObservedValueOf<O>>

以上内容是否对您有帮助:
在线笔记
App下载
App下载

扫描二维码

下载编程狮App

公众号
微信公众号

编程狮公众号