WebSocketSubject

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>)

Properties

方法

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

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)

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

returns Subscription