Options
All
  • Public
  • Public/Protected
  • All
Menu

Class RxSocketSubject<T>

Defines a 2-way duplex stream, where the caller can send data across the "onSend" stream and listen for responses from the "onReceive" stream.

Use the send() method to perform a round-trip operation, and wait on receiver results directly.

Type parameters

  • T

Hierarchy

Implements

Index

Constructors

Properties

Methods

Constructors

constructor

  • new RxSocketSubject<T>(onSend?: Subscribable<T>, onReceive?: Subscribable<T>): RxSocketSubject<T>

Properties

Protected Readonly mOnSendSubject

mOnSendSubject: Subject<T>

Readonly onReceive

onReceive: Observable<T>

Protected Readonly onReceiveProxy

onReceiveProxy: ProxyObservable<T>

Readonly onSend

onSend: Observable<T>

Protected Readonly onSendProxy

onSendProxy: ProxyObservable<T>

Methods

destroy

  • destroy(errorMessage?: string): void

emit

  • emit(value: T): void

intercept

isDestroyed

  • isDestroyed(): boolean

pipe

  • pipe(onSend: Subscribable<T>, onReceive: Subscribable<T>): void

send

  • send(value: T): Observable<T>

setReceiveSource

  • setReceiveSource(source: Subscribable<T>): void

setSendSource

  • setSendSource(source: Subscribable<T>): void

toReadOnly

Generated using TypeDoc