ObservationSink

import type { ObservationSink } from "@elie-laloum/outpost";

Parameters and properties

observeRequired
(observation: Observation) => void | Promise<void>
Receive one envelope; returned promises are serialized per sink and rejection is isolated from execution.
flushOptional
(() => void | Promise<void>) | undefined
Drains the receiver’s own buffer; the hub calls it from flush() with its delivery timeout.

Signature

export interface ObservationSink {
  observe(observation: Observation): void | Promise<void>;
  flush?(): void | Promise<void>;
}

Observation