import type { Stream } from "effect";
import { Context, Effect, Layer } from "effect";
import type { Abi, Address, TransactionReceipt } from "viem";
import type { ClientNotFoundError, EventDecodeError } from "../core/index.js";
import { EventWatchError, PublicClientService } from "../core/index.js";
import type { DecodedEvent } from "../events/index.js";
import type { ContractEventName } from "../types/index.js";
export type WatchParams<TAbi extends Abi, TEventName extends ContractEventName<TAbi>> = {
    chainId: number;
    address?: Address;
    abi: TAbi;
    eventName: TEventName;
    fromBlock?: bigint;
    pollingInterval?: number;
};
export type EventStreamShape = {
    readonly watch: <TAbi extends Abi, TEventName extends ContractEventName<TAbi>>(params: WatchParams<TAbi, TEventName>) => Effect.Effect<Stream.Stream<DecodedEvent<TAbi, TEventName>, EventWatchError>, ClientNotFoundError>;
    readonly decodeReceipt: <TAbi extends Abi>(receipt: TransactionReceipt, abi: TAbi) => Effect.Effect<DecodedEvent<TAbi, ContractEventName<TAbi>>[], EventDecodeError>;
};
declare const EventStream_base: Context.TagClass<EventStream, "ew3/EventStream", EventStreamShape>;
export declare class EventStream extends EventStream_base {
}
export declare const EventStreamLive: Layer.Layer<EventStream, never, PublicClientService>;
export {};
//# sourceMappingURL=stream.d.ts.map