Class MemoryBackplane

constructor

• new MemoryBackplane(
      origin: string,
      bus?: string,
      reporter?: IRealtimeHandlerErrorReporter,
  ): MemoryBackplane

  Parameters

  • origin: string

    This instance's identity

  • bus: string = 'default'

    The process-wide bus name to join

  • Optionalreporter: IRealtimeHandlerErrorReporter

    Optional subscriber failure and recovery sink; history is always retained

  Returns MemoryBackplane

Readonlyorigin

handlerErrors

• get handlerErrors(): readonly Error[]

  The most recent 100 errors thrown by subscribers during delivery, oldest first.

  Returns readonly Error[]

close

• close(): Promise<void>

  Closes the underlying transport and drops every handler.

  Returns Promise<void>

connect

• connect(): Promise<void>

  Opens the underlying transport. Idempotent.

  Returns Promise<void>

isHealthy

• isHealthy(): Promise<boolean>

  M70c: a real single-process bus has no backend to be unreachable, so it is always reachable. There is no external dependency whose outage could make this transport down (M47).

  Returns Promise<boolean>

  true

  Since

  0.2.0

publish

• publish(frame: RealtimeFrame): Promise<void>

  Publishes a frame to every other subscribed instance.

  The frame is not delivered back to this instance's own handlers — a local broadcast has already reached local members directly, and redelivering it would double-send.

  Parameters

  • frame: RealtimeFrame

    The frame to publish

  Returns Promise<void>

subscribe

• subscribe(handler: RealtimeFrameHandler): Promise<() => void>

  Registers a handler for frames arriving from other instances.

  May be called more than once; each consumer plugin registers its own.

  Parameters

  • handler: RealtimeFrameHandler

    Invoked per arriving frame

  Returns Promise<() => void>

  A function that removes this handler