Aller au contenu
English

ObservationSink

import type { ObservationSink } from "@elie-laloum/outpost";
  • observeRequis
    (observation: Observation) => void | Promise<void>
    Reçoit une enveloppe ; les promesses retournées sont sérialisées par récepteur et leurs rejets sont isolés de l’exécution.
  • flushOptionnel
    (() => void | Promise<void>) | undefined
    Vide le tampon propre au récepteur ; le hub l’appelle depuis flush() avec son délai de livraison.
export interface ObservationSink {
  observe(observation: Observation): void | Promise<void>;
  flush?(): void | Promise<void>;
}