RxJS multicast

2020-10-13 10:23 更新

返回一個(gè)Observable，該對(duì)象發(fā)出對(duì)共享基礎(chǔ)底層流的單個(gè)預(yù)訂的ConnectableObservable發(fā)出的項(xiàng)目調(diào)用指定選擇器的結(jié)果。

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

參量

subjectOrSubjectFactory 工廠函數(shù)創(chuàng)建一個(gè)中間主題，通過該主題，源序列的元素將被多播到選擇器函數(shù)或主題，以將源元素推入其中。
選擇器 可選的。 默認(rèn)值為 undefined。  可選的選擇器功能，可以根據(jù)需要多次使用多播的源流，而不會(huì)導(dǎo)致對(duì)該源流的多次訂閱。給定來源的訂閱者將從訂閱開始就接收該來源的所有通知。

returns

OperatorFunction<T, R>：一個(gè)Observable，它發(fā)出對(duì)選擇器調(diào)用的結(jié)果，該選擇器由ConnectableObservable共享單個(gè)訂閱到基礎(chǔ)流的a發(fā)出的項(xiàng)目組成。

描述

multicast marble diagram

超載

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

參量 類型
學(xué)科 類型： Subject

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

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

參量 類型
學(xué)科 類型： 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>>

以上內(nèi)容是否對(duì)您有幫助：
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

公眾號(hào)
微信公眾號(hào)

編程獅公眾號(hào)