Class BrokerChannel<T>

Type Parameters

  • T

Hierarchy

  • BrokerChannel

Constructors

constructor

Properties

callbacks channel client decoder listener type wrapped

Methods

next publish subscribe

Constructors

constructor

Properties

Protected callbacks

callbacks: ((next: Uint8Array) => void)[] = []

channel

channel: string

Protected client

client: BrokerClient

Protected decoder

decoder: ((bson: Uint8Array) => any)

Type declaration

    • (bson: Uint8Array): any

    • Parameters

      • bson: Uint8Array

      Returns any

Protected listener

listener: number = 0

Protected type

type: Type

Protected wrapped

wrapped: boolean = false

Methods

next

publish

subscribe

  • Parameters

    • callback: ((next: T) => void)
        • (next: T): void

        • Parameters

          • next: T

          Returns void

    Returns Promise<AsyncSubscription>

Settings

Member Visibility

Theme

Generated using TypeDoc