Skip to main content

OmniaStream

@totemsdk/omnia


@totemsdk/omnia / OmniaStream

Class: OmniaStream

Constructors

Constructor

new OmniaStream(_stream): OmniaStream

Parameters

_stream

IStreamTransport

Returns

OmniaStream

Methods

destroy()

destroy(): void

Returns

void


onClose()

onClose(cb): Unsubscribe

Parameters

cb

() => void

Returns

Unsubscribe


onError()

onError(cb): Unsubscribe

Parameters

cb

(err) => void

Returns

Unsubscribe


onMessage()

onMessage(cb): Unsubscribe

Parameters

cb

(msg) => void

Returns

Unsubscribe


reset()

reset(): void

Returns

void


send()

send(msg): Promise<void>

Parameters

msg

OmniaMessage

Returns

Promise<void>