export declare const StatsCollectMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    type: "stats.collect";
    streamId: string;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
}, {}>;
export type StatsCollectMsg = typeof StatsCollectMsg.infer;
export declare const isStatsCollect: (msg: unknown, streamId?: string) => msg is StatsCollectMsg;
export declare function createStatsCollector<T>(streamId: string, intervalMs?: number): TransformStream<T, T | StatsCollectMsg>;