import { remote_live_stream } from "./internal/live.js";
import type { RemoteFailure } from "./remote/shared.js";
import { Effect, Stream } from "effect";
declare const live_operator: unique symbol;
type RemoteLivePipe<A, E> = {
    (): RemoteLiveStream<A, E>;
    (ab: LiveFactory["status"]): Stream.Stream<LiveStatus, never, never>;
    (ab: LiveFactory["reconnect"]): Effect.Effect<void, RemoteFailure<E>, never>;
    <B>(ab: LiveFactory["status"], bc: (_: Stream.Stream<LiveStatus, never, never>) => B): B;
    <B>(ab: LiveFactory["reconnect"], bc: (_: Effect.Effect<void, RemoteFailure<E>, never>) => B): B;
    <B, C>(ab: LiveFactory["status"], bc: (_: Stream.Stream<LiveStatus, never, never>) => B, cd: (_: B) => C): C;
    <B, C>(ab: LiveFactory["reconnect"], bc: (_: Effect.Effect<void, RemoteFailure<E>, never>) => B, cd: (_: B) => C): C;
    <B>(ab: (_: Stream.Stream<A, RemoteFailure<E>, never>) => Stream.Stream<B, RemoteFailure<E>, never>): RemoteLiveStream<B, E>;
    <B>(ab: (_: Stream.Stream<A, RemoteFailure<E>, never>) => B): B;
    <B, C>(ab: (_: Stream.Stream<A, RemoteFailure<E>, never>) => B, bc: (_: B) => C): C;
    <B, C, D>(ab: (_: Stream.Stream<A, RemoteFailure<E>, never>) => B, bc: (_: B) => C, cd: (_: C) => D): D;
};
/**
 * Stream returned by `Query.live` remote functions.
 *
 * @example
 * ```ts
 * const Time = GetTime();
 * const Label = Time.pipe(Stream.map((time) => time.toISOString()));
 * ```
 *
 * @since 3.4.8
 */
export type RemoteLiveStream<A, E = never> = Omit<Stream.Stream<A, RemoteFailure<E>, never>, "pipe"> & {
    readonly [remote_live_stream]: true;
    readonly pipe: RemoteLivePipe<A, E>;
};
/**
 * Transport state exposed separately from the data stream.
 *
 * @example
 * ```ts
 * const Status = GetTime().pipe(Live.status);
 * ```
 *
 * @since 3.4.8
 */
export type LiveStatus = {
    readonly _tag: "Idle";
} | {
    readonly _tag: "Connecting";
} | {
    readonly _tag: "Open";
} | {
    readonly _tag: "Failed";
    readonly cause: unknown;
} | {
    readonly _tag: "Closed";
};
/**
 * Public live stream control helpers.
 *
 * @example
 * ```ts
 * yield* GetNotifications().pipe(Live.reconnect);
 * ```
 *
 * @since 3.4.8
 */
export interface LiveFactory {
    readonly status: {
        readonly [live_operator]: true;
        /**
         * Creates a stream of transport status updates for a remote live stream.
         *
         * @example
         * ```ts
         * const Status = GetTime().pipe(Live.status);
         * ```
         *
         * @param stream - Remote live stream whose transport status should be read.
         * @returns A stream of transport status snapshots.
         */
        <A, E>(stream: RemoteLiveStream<A, E>): Stream.Stream<LiveStatus, never, never>;
    };
    readonly reconnect: {
        readonly [live_operator]: true;
        /**
         * Reconnects the transport behind a remote live stream.
         *
         * @example
         * ```ts
         * yield* GetNotifications().pipe(Live.reconnect);
         * ```
         *
         * @param stream - Remote live stream whose transport should reconnect.
         * @returns An Effect that completes after the reconnect request is sent.
         */
        <A, E>(stream: RemoteLiveStream<A, E>): Effect.Effect<void, RemoteFailure<E>, never>;
    };
}
export declare function make_remote_live_stream<A, ErrorType = never>(resource: unknown, on_error: (error: unknown) => RemoteFailure<ErrorType>, encode_snapshot?: (value: unknown) => string): RemoteLiveStream<A, ErrorType>;
export declare function make_failed_remote_live_stream<A, ErrorType = never>(error: unknown, on_error: (error: unknown) => RemoteFailure<ErrorType>): RemoteLiveStream<A, ErrorType>;
/**
 * Remote live transport helpers.
 *
 * @since 3.4.8
 */
export declare const Live: LiveFactory;
export declare function get_native_remote_live_resource(value: unknown): unknown | undefined;
export {};