import { AsyncStream, AsyncIterableSubject } from 'data-async-iterators';
import { Semaphore } from "data-semaphore";
/**
 * @category composable/executors
 */
export declare class Hookable {
    hooks: Map<string, Hook>;
    allowImplicitCreation: boolean;
    has(name: string): boolean;
    create<T = any>(name: string): Hook<T>;
    get(name: string): Hook<any>;
    subscribe<T = any>(name: string, subscription: HookSubscription<T>): HookSubscriptionCancellation;
    unsubscribe<T = any>(name: string, subscription: HookSubscription<T>): void;
    notify<T = any>(name: string, arg?: T): Promise<void>;
}
/**
 * @category composable/executors
 */
export interface HookSubscription<T> {
    (arg: T): void | Promise<void>;
}
/**
 * @category composable/executors
 */
export interface HookSubscriptionCancellation {
    (): void;
}
/**
 * @category composable/executors
 */
export declare class Hook<T = any> {
    name: string;
    protected subscriptions: HookSubscription<T>[];
    protected notificationSemaphore: Semaphore;
    allowConcurrentNotifications: boolean;
    constructor(name: string);
    setSequential(): this;
    setParallel(): this;
    subscribe(callback: HookSubscription<T>): HookSubscriptionCancellation;
    unsubscribe(callback: HookSubscription<T>): void;
    isSubscribed(): boolean;
    notify(arg?: T): Promise<void>;
    toPromise(errorHook?: Hook<unknown>): Promise<T>;
    toAsyncStream(errorHook?: Hook<unknown>, endHook?: Hook<unknown>): AsyncStream<T>;
    [Symbol.asyncIterator](): AsyncIterator<T, any, undefined>;
}
/**
 * @category composable/executors
 */
export declare class HookAsyncIterator<T> extends AsyncIterableSubject<T> implements AsyncIterableIterator<T> {
    protected release: HookSubscriptionCancellation;
    protected releaseError: HookSubscriptionCancellation;
    protected releaseEnd: HookSubscriptionCancellation;
    constructor(hook: Hook<T>, errorHook?: Hook<unknown>, endHook?: Hook<unknown>);
    protected releaseAllHooks(): void;
}