Options
All
  • Public
  • Public/Protected
  • All
Menu

Class StreamRegistryImpl

Internal registry for Subscription streams.

Hierarchy

  • StreamRegistryImpl

Implements

Index

Constructors

constructor

  • Create a new StreamRegistry instance

    Parameters

    Returns StreamRegistryImpl

Properties

fallbacks

fallbacks: StreamAdapter[] = []

The fallback stream adapters

streams

streams: Map<TopicSelector, StreamAdapter[]> = new Map()

The stream adapters organised by the topic selector

topicCache

topicCache: TopicCache

The topic cache

Methods

add

  • Add a stream to the registry

    Parameters

    Returns void

addFallback

  • Add a fallback stream to the registry

    Parameters

    Returns void

close

  • close(): void
  • Close the stream registry

    All streams will receive an SESSION_CLOSED subscription error. No further values will be emitted.

    Returns void

getFallbacks

  • Get the fallback stream for a given topic specification

    Parameters

    Returns StreamAdapter[]

    an array of stream adapters that select the topic specification

remove

  • Remove a stream from the registry

    Parameters

    Returns void

streamsFor

  • Get the streams for a topic path that match a topic specification

    Parameters

    Returns StreamAdapter[]

    an array of stream adapters that select the topic specification