export type HostActions = Readonly<{ complete: () => Promise; next: (action: Action) => void; waitForAction: (select: (action: Action) => action is Selected) => Promise; waitForIdle: () => Promise; }>; /** * Executes semantic host actions one at a time while keeping source admission synchronous. * * `concatMap` is the sole effect serializer: each deferred reducer call starts only after the prior Promise settles. Errors are * converted to empty inner streams so one failed physical transaction is reported without terminating later host actions. * Barrier envelopes participate in the same ordering but run no effect; resolving one proves every action admitted before it * has settled. `waitForAction` observes this same admission edge for lifecycle gates without introducing a forwarding Subject. * Completing the source drains already-admitted effects and gives shutdown one Promise for final quiescence. */ export declare function createHostActions(apply: (action: Action) => void | Promise, reportError: (action: Action, error: unknown) => void): HostActions;