Class WorkerValueStreamResponder

An adapter that listens to value stream events in the shared worker and sends the events to the registry proxy in the tab

Hierarchy

WorkerValueStreamResponder

Index

Constructors

constructor

Properties

Methods

Constructors

constructor

new WorkerValueStreamResponder(registry: StreamRegistry, selector: TopicSelector, datatype: DataType<any, any, any> | AnyDataType, fallback: boolean, respond: WorkerStreamResponse, adapterId: ConversationId): WorkerValueStreamResponder

- Defined in internal/webworker/topics/worker-stream-registry-adapter.ts:60
Parameters
- registry: StreamRegistry
- selector: TopicSelector
- datatype: DataType<any, any, any> | AnyDataType
- fallback: boolean
- respond: WorkerStreamResponse
- adapterId: ConversationId
Returns WorkerValueStreamResponder

Properties

Private adapterId

adapterId: ConversationId

Private respond

respond: WorkerStreamResponse

valueStream

valueStream: WorkerValueStreamProxy

The value stream that receives the events

Methods

onOpen

onOpen(): void

- Defined in internal/webworker/topics/worker-stream-registry-adapter.ts:82
Handle the open event

Returns void

onSubscription

onSubscription(path: string, specification: TopicSpecification): void

- Defined in internal/webworker/topics/worker-stream-registry-adapter.ts:118
Handle a subscription event

Parameters
- path: string
  
  the topic path
- specification: TopicSpecification
  
  the topic specification
Returns void

onSubscriptionError

onSubscriptionError(error: any): void

- Defined in internal/webworker/topics/worker-stream-registry-adapter.ts:153
Handle a subscription error

Parameters
- error: any
  
  the error
Returns void

onUnsubscription

onUnsubscription(path: string, specification: TopicSpecification, reason: UnsubscribeReason): void

- Defined in internal/webworker/topics/worker-stream-registry-adapter.ts:135
Handle a subscription event

Parameters
- path: string
  
  the topic path
- specification: TopicSpecification
  
  the topic specification
- reason: UnsubscribeReason
  
  the reason for unsubscribing
Returns void

onValue

onValue(path: string, specification: TopicSpecification, newValue: Buffer, oldValue: Buffer | null): void

- Defined in internal/webworker/topics/worker-stream-registry-adapter.ts:96
Handle a value event

Parameters
- path: string
  
  the topic path
- specification: TopicSpecification
  
  the topic specification
- newValue: Buffer
  
  the new value
- oldValue: Buffer | null
  
  the old value
Returns void