import { Context, Effect, Layer, Stream } from "effect";
import type { Abi, Address } from "viem";
import type { ClientNotFoundError, EventWatchError } from "../core/index.js";
import { PublicClientService } from "../core/index.js";
import type { DecodedEvent } from "../events/index.js";
import { EventStream } from "../events/index.js";
import type { ContractEventName } from "../types/index.js";
export type ReliableWatchParams<TAbi extends Abi, TEventName extends ContractEventName<TAbi>> = {
    chainId: number;
    address?: Address;
    abi: TAbi;
    eventName: TEventName;
    fromBlock?: bigint;
    pollingInterval?: number;
    confirmations?: number;
};
export type ReliableEventStreamShape = {
    readonly watch: <TAbi extends Abi, TEventName extends ContractEventName<TAbi>>(params: ReliableWatchParams<TAbi, TEventName>) => Effect.Effect<Stream.Stream<DecodedEvent<TAbi, TEventName>, EventWatchError>, ClientNotFoundError>;
};
declare const ReliableEventStream_base: Context.TagClass<ReliableEventStream, "ew3/ReliableEventStream", ReliableEventStreamShape>;
export declare class ReliableEventStream extends ReliableEventStream_base {
}
export declare const ReliableEventStreamLive: Layer.Layer<ReliableEventStream, never, PublicClientService | EventStream>;
export {};
//# sourceMappingURL=reliable-stream.d.ts.map