Options
All
  • Public
  • Public/Protected
  • All
Menu

Class ValueStreamProxy

Internal proxy for Subscriptions with an underlying datatype.

Hierarchy

  • ValueStreamProxy

Implements

  • any

Index

Constructors

constructor

Properties

Private adapterFactory

adapterFactory: AdapterFactory

Private datatype

datatype: AbstractDataType<any, any, any> | AnyDataTypeImpl

The data type of the value stream

emitter

emitter: Emitter

The emitter that emits events on the subscription

Private pending

pending: boolean = true

Flag indicating that the stream has not yet been added to the stream registry

Private registry

registry: StreamRegistry

The stream registry

subscription

subscription: ValueStreamImpl

The subscription that is returned to the user

Methods

adapter

onDelta

  • onDelta(path: string, specification: TopicSpecification, oldContent: Buffer | null, content: Buffer, delta: BinaryDelta | null, oldValue: any, newValue: any): void
  • inheritdoc

    Parameters

    Returns void

onOpen

  • onOpen(): void
  • inheritdoc

    Returns void

onSubscription

  • inheritdoc

    Parameters

    Returns void

onSubscriptionError

  • inheritdoc

    Parameters

    Returns void

onUnsubscription

onValue

  • onValue(path: string, specification: TopicSpecification, oldContent: Buffer | null, content: Buffer, oldValue: any, newValue: any): void
  • inheritdoc

    Parameters

    • path: string
    • specification: TopicSpecification
    • oldContent: Buffer | null
    • content: Buffer
    • oldValue: any
    • newValue: any

    Returns void

selects

  • inheritdoc

    Parameters

    Returns any