import type { LineStreamMsg } from "./line-stream.js";
export declare const DataBeginMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    type: "data.begin";
    streamId: string;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
}, {}>;
export declare const DataLineMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    type: "data.line";
    streamId: string;
    json: unknown;
    dataLineNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
}, {}>;
export declare const DataErrorMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    type: "data.error";
    streamId: string;
    message: string;
    dataLineNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
}, {}>;
export declare const DataEndMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    type: "data.end";
    streamId: string;
    totalDataLines: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
}, {}>;
export declare const DataStatsMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    type: "data.stats";
    streamId: string;
    stats: {
        dataLineNr: number;
    };
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
}, {}>;
export declare const DataStreamMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    type: "data.begin";
    streamId: string;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
} | {
    type: "data.line";
    streamId: string;
    json: unknown;
    dataLineNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
} | {
    type: "data.error";
    streamId: string;
    message: string;
    dataLineNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
} | {
    type: "data.end";
    streamId: string;
    totalDataLines: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
} | {
    type: "data.stats";
    streamId: string;
    stats: {
        dataLineNr: number;
    };
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
}, {}>;
export type DataBeginMsg = typeof DataBeginMsg.infer;
export type DataLineMsg = typeof DataLineMsg.infer;
export type DataEndMsg = typeof DataEndMsg.infer;
export type DataStatsMsg = typeof DataStatsMsg.infer;
export type DataErrorMsg = typeof DataErrorMsg.infer;
export type DataStreamMsg = typeof DataStreamMsg.infer;
export declare const isDataBegin: (msg: unknown, streamId?: string) => msg is DataBeginMsg;
export declare const isDataLine: (msg: unknown, streamId?: string) => msg is DataLineMsg;
export declare const isDataEnd: (msg: unknown, streamId?: string) => msg is DataEndMsg;
export declare const isDataStats: (msg: unknown, streamId?: string) => msg is DataStatsMsg;
export declare const isDataMsg: (msg: unknown, streamId?: string) => msg is DataStreamMsg;
export declare const isDataError: (msg: unknown, streamId?: string) => msg is DataErrorMsg;
export declare function createDataStream(filterStreamId: string): TransformStream<LineStreamMsg, DataStreamMsg>;