/**
 * Zap<T> -- push-based event channel via PubSub.
 *
 * @module
 */
import { Effect, Stream } from 'effect';
import type { Scope } from 'effect';
import type { Millis } from './brands.js';
interface ZapShape<T> {
    readonly _tag: 'Zap';
    readonly stream: Stream.Stream<T>;
    emit(value: T): Effect.Effect<void>;
}
/**
 * Zap -- push-based event channel backed by Effect PubSub.
 * Provides reactive event streams with map, filter, merge, debounce, and throttle.
 *
 * @example
 * ```ts
 * const program = Effect.scoped(Effect.gen(function* () {
 *   const zap = yield* Zap.make<number>();
 *   const doubled = yield* Zap.map(zap, n => n * 2);
 *   yield* zap.emit(5);
 *   // doubled.stream receives 10
 * }));
 * ```
 */
export declare const Zap: {
    make: <T>() => Effect.Effect<ZapShape<T>, never, Scope.Scope>;
    fromDOMEvent: <K extends keyof HTMLElementEventMap>(element: HTMLElement, event: K) => Effect.Effect<ZapShape<HTMLElementEventMap[K]>, never, Scope.Scope>;
    merge: <T>(events: ReadonlyArray<ZapShape<T>>) => Effect.Effect<ZapShape<T>, never, Scope.Scope>;
    map: <A, B>(event: ZapShape<A>, f: (a: A) => B) => Effect.Effect<ZapShape<B>, never, Scope.Scope>;
    filter: <T>(event: ZapShape<T>, predicate: (value: T) => boolean) => Effect.Effect<ZapShape<T>, never, Scope.Scope>;
    debounce: <T>(event: ZapShape<T>, ms: Millis) => Effect.Effect<ZapShape<T>, never, Scope.Scope>;
    throttle: <T>(event: ZapShape<T>, ms: Millis) => Effect.Effect<ZapShape<T>, never, Scope.Scope>;
};
export declare namespace Zap {
    /** Structural shape of a {@link Zap}: event-sourced reactive primitive exposing a discrete stream. */
    type Shape<T> = ZapShape<T>;
}
export {};
//# sourceMappingURL=zap.d.ts.map