Options
All
  • Public
  • Public/Protected
  • All
Menu

Class Pipe<C, T>

Type parameters

  • C

  • T

Hierarchy

Implements

Index

Properties

Methods

Properties

Protected bus

bus: Emittery = new Emittery()

Protected frames

frames: Uint8Array[] = [] as Uint8Array[]

Protected transcoder

transcoder: FrameTranscoder<T> = new FrameTranscoder<T>()

Methods

Abstract close

  • close(): Promise<void>

Protected getReadKey

  • getReadKey(): string

Abstract open

  • open(config: C): Promise<void>

Protected queue

  • queue(frame: Frame<T>): Promise<void>

read

  • read(): Promise<Frame<T>>

Abstract write

  • write(resourceType: T, resourceId: string, msg: Uint8Array, nodeId: string): Promise<void>

  • Parameters

    • resourceType: T
    • resourceId: string
    • msg: Uint8Array
    • nodeId: string

    Returns Promise<void>

Generated using TypeDoc