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>