WebSocketSubject

2020-10-13 18:15 更新
class WebSocketSubject<T> extends AnonymousSubject {
  constructor(urlConfigOrSource: string | WebSocketSubjectConfig<T> | Observable<T>, destination?: Observer<T>)
  _output: Subject<T>
  lift<R>(operator: Operator<T, R>): WebSocketSubject<R>
  multiplex(subMsg: () => any, unsubMsg: () => any, messageFilter: (value: T) => boolean)
  _subscribe(subscriber: Subscriber<T>): Subscription
  unsubscribe()
}

建設(shè)者

? constructor(urlConfigOrSource: string | WebSocketSubjectConfig<T> | Observable<T>, destination?: Observer<T>)

參量 類型
urlConfigOrSource 類型: string WebSocketSubjectConfig Observable
destination 可選的。 默認(rèn)值為 undefined。         類型: Observer。

Properties

屬性 類型 描述
_輸出 Subject<T>

方法

lift() lift<R>(operator: Operator<T, R>): WebSocketSubject<R>

參量 類型
operator 類型: Operator

returns WebSocketSubject<R>

multiplex() 創(chuàng)建一個(gè) Observable,當(dāng)訂閱時(shí)發(fā)送一條消息, 由 定義,通過 subMsg函數(shù) 套接字到服務(wù)器開始 通過該套接字訂閱數(shù)據(jù)。 數(shù)據(jù)到達(dá)后, messageFilter參數(shù)將用于選擇適當(dāng)?shù)臄?shù)據(jù) 產(chǎn)生的 Observable。 發(fā)生拆卸時(shí),可能是由于 取消訂閱,完成或錯(cuò)誤,由 unsubMsg 參數(shù)將通過 WebSocketSubject 發(fā)送到服務(wù)器。

multiplex(subMsg: () => any, unsubMsg: () => any, messageFilter: (value: T) => boolean)

參量 類型
subMsg 生成要發(fā)送到的訂閱消息的功能  服務(wù)器。 序列化程序仍會(huì)在   WebSocketSubject 的配置。(默認(rèn)為JSON 序列化)
unsubMsg 生成要取消訂閱消息的功能  在拆卸時(shí)發(fā)送到服務(wù)器。 這仍將由  WebSocketSubject 的配置中的序列化器。
messageFilter 選擇適當(dāng)消息的謂詞  從服務(wù)器獲取輸出流。

subscribe() _subscribe(subscriber: Subscriber<T>): Subscription

參量 類型
訂閱用戶 類型: Subscriber

returns Subscription

unsubscribe()
unsubscribe()      參量  沒有參數(shù)。
以上內(nèi)容是否對(duì)您有幫助:
在線筆記
App下載
App下載

掃描二維碼

下載編程獅App

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

編程獅公眾號(hào)