Share via

Subject class

Package:
@microsoft/signalr

Stream implementation to stream items to the server.

Constructors

Subject()

Properties

cancelCallback
observers

Methods

complete()
error(any)
next(T)
subscribe(IStreamSubscriber<T>)

Constructor Details

Subject() 

new Subject()

Property Details

cancelCallback 

public cancelCallback?: () => Promise<void>

Property Value

() => Promise<void>

observers 

public observers: IStreamSubscriber<T>[]

Property Value

IStreamSubscriber<T>[]

Method Details

complete() 

function complete()

error(any) 

function error(err: any)

Parameters

err

any

next(T) 

function next(item: T)

Parameters

item

T

subscribe(IStreamSubscriber<T>) 

function subscribe(observer: IStreamSubscriber<T>): ISubscription<T>

Parameters

observer

IStreamSubscriber<T>

Returns

ISubscription<T>