export type WriteonlyEventAction = { emit(value: T): void; }; export declare class EventAction implements WriteonlyEventAction { private readonly combine?; private readonly neutral?; private latestTime; private readonly subscriptionListeners; private readonly readers; constructor(combine?: ((...values: Array) => T) | undefined, neutral?: T | undefined); emit(value: T): void; subscribe(callback: (value: T) => void, options?: { once?: true; signal?: AbortSignal; }): void; waitFor(signal?: AbortSignal): Promise; getLatestTime(): number; createReader(abortSignal: AbortSignal): { update(): void; get(): T; }; mapFrom(fn: (value: S) => T, abortSignal?: AbortSignal): EventAction; filterFrom(fn: (value: T) => boolean, abortSignal?: AbortSignal): EventAction; } export type StateActionWriter = { write(value: T): void; }; /** * StateAction keeps the latest state per writer and merges them on read. * Values persist until the writer is disposed (abortSignal aborts). */ export declare class StateAction { private readonly mergeWriters?; private readonly neutral?; private readonly absoluteActions; constructor(mergeWriters?: ((...values: Array) => T) | undefined, neutral?: T | undefined); createWriter(abortSignal: AbortSignal): StateActionWriter; get(): T; mapFrom(fn: (value: S) => T): StateAction; }