import { n as EventTag, o as EventaMatchExpression, r as Eventa } from "./eventa-CCPqecvv.mjs";

//#region src/context-hooks.d.ts
interface EventaAdapterProps<EmitOptions = any> {
  cleanup: () => void;
  hooks: {
    /**
     * When `ctx.on`, `ctx.once` called, call `onReceived`
     */
    onReceived: <Req, Res>(tag: EventTag<Req, Res>, payload: Req) => void;
    /**
     * When `ctx.emit` called, call `onSent`
     */
    onSent: <Req, Res>(tag: EventTag<Req, Res>, payload: Req, options?: EmitOptions) => void;
  };
}
type EventaAdapter<EmitOptions = any> = <P>(emit: (event: Eventa<P>, payload: P, options?: EmitOptions) => void) => EventaAdapterProps;
//#endregion
//#region src/context.d.ts
interface CreateContextProps<EmitOptions = any> {
  adapter?: EventaAdapter<EmitOptions>;
}
declare function createContext<Extensions = any, Options = {
  raw?: any;
}>(props?: CreateContextProps<Options>): EventContext<Extensions, Options>;
interface EventContext<Extensions = undefined, EmitOptions = undefined> {
  listeners: Map<EventTag<any, any>, Set<(params: any) => any>>;
  onceListeners: Map<EventTag<any, any>, Set<(params: any) => any>>;
  emit: <P>(event: Eventa<P>, payload: P, options?: EmitOptions) => Promise<void>;
  on: <P>(eventOrMatchExpression: Eventa<P> | EventaMatchExpression<P>, handler: (payload: Eventa<P>, options?: EmitOptions) => any) => () => void;
  once: <P>(eventOrMatchExpression: Eventa<P> | EventaMatchExpression<P>, handler: (payload: Eventa<P>, options?: EmitOptions) => any) => () => void;
  off: <P>(eventOrMatchExpression: Eventa<P> | EventaMatchExpression<P>, handler?: (payload: Eventa<P>, options?: EmitOptions) => any) => void;
  /**
   * Lifetime signal for this context. Aborts when `abort()` is called by an
   * adapter (e.g. ws close, broadcast-channel dispose, worker error). Every
   * `defineInvoke(...)` derived from this ctx hooks this signal so transport
   * death cascades into a single synchronous reject of every in-flight invoke.
   *
   * Mirrors Go's `context.Context` lifetime semantics: one signal, many
   * derived operations, one cancel cascades to all.
   */
  signal: AbortSignal;
  /**
   * Abort this context's lifetime signal. Adapters call this at transport-death
   * points; the `reason` flows through to `invoke()` promise rejections so
   * callers see a meaningful Error rather than a generic AbortError.
   *
   * Idempotent — repeated calls are no-ops.
   */
  abort: (reason?: unknown) => void;
  /**
   * Extensions (adapter-specific).
   *
   * Known usage: webworkers/worker-threads populate internal invoke config via
   * `extensions.__internal.invoke` to abort pending invokes on fatal errors.
   */
  extensions?: Extensions;
}
type EventContextEmitFn = EventContext['emit'];
//#endregion
export { EventContextEmitFn as n, createContext as r, EventContext as t };
//# sourceMappingURL=context-C4Cia9QU.d.mts.map