import type { Layer } from "effect";
import { Effect, Stream, SubscriptionRef } from "effect";
import type { Address, Block, Hash, Hex, Log } from "viem";
import type { SubscriptionConnectionState, SubscriptionRetryConfig } from "../subscriptions/index.js";
import { SubscriptionService } from "../subscriptions/index.js";
export type MockSubscriptionServiceConfig = {
    watchBlocks?: (params: {
        chainId: number;
        includeTransactions?: boolean;
        pollingInterval?: number;
    }) => Effect.Effect<Stream.Stream<Block, never>>;
    watchLogs?: (params: {
        chainId: number;
        address?: Address | Address[];
        topics?: (Hex | Hex[] | null)[];
        pollingInterval?: number;
    }) => Effect.Effect<Stream.Stream<Log, never>>;
    watchPendingTransactions?: (params: {
        chainId: number;
        pollingInterval?: number;
    }) => Effect.Effect<Stream.Stream<Hash, never>>;
    watchBlocksRetrying?: (params: {
        chainId: number;
        includeTransactions?: boolean;
        pollingInterval?: number;
        retry?: SubscriptionRetryConfig;
    }) => Effect.Effect<{
        stateRef: SubscriptionRef.SubscriptionRef<SubscriptionConnectionState>;
        stream: Stream.Stream<Block, never>;
    }>;
    watchLogsRetrying?: (params: {
        chainId: number;
        address?: Address | Address[];
        topics?: (Hex | Hex[] | null)[];
        pollingInterval?: number;
        retry?: SubscriptionRetryConfig;
    }) => Effect.Effect<{
        stateRef: SubscriptionRef.SubscriptionRef<SubscriptionConnectionState>;
        stream: Stream.Stream<Log, never>;
    }>;
    watchPendingTransactionsRetrying?: (params: {
        chainId: number;
        pollingInterval?: number;
        retry?: SubscriptionRetryConfig;
    }) => Effect.Effect<{
        stateRef: SubscriptionRef.SubscriptionRef<SubscriptionConnectionState>;
        stream: Stream.Stream<Hash, never>;
    }>;
    hasWebSocket?: (chainId: number) => Effect.Effect<boolean>;
};
export declare const makeMockSubscriptionServiceLayer: (config?: MockSubscriptionServiceConfig, supportedChainId?: number) => Layer.Layer<SubscriptionService>;
//# sourceMappingURL=mock-subscription-service.d.ts.map