import { LineStreamMsg } from "./line-stream.js";
import { StatsCollectMsg } from "./stats-stream.js";
import { DeltaStreamMsg } from "./delta-stream.js";
export declare const BlockBase: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
}, {}>;
export declare const BlockStats: import("arktype/internal/variants/object.ts").ObjectType<{
    lines: number;
    bytes: number;
    cnt?: number | undefined;
}, {}>;
export type BlockStats = typeof BlockStats.infer;
export declare const BlockBeginMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.begin";
}, {}>;
export declare const BlockUsage: import("arktype/internal/variants/object.ts").ObjectType<{
    given: {
        prompt_tokens: number;
        completion_tokens: number;
        total_tokens: number;
    }[];
    calculated: {
        prompt_tokens: number;
        completion_tokens: number;
        total_tokens: number;
    };
}, {}>;
export type BlockUsage = typeof BlockUsage.infer;
export declare const FileSystemRefFields: import("arktype/internal/variants/object.ts").ObjectType<{
    appSlug: string;
    ownerHandle: string;
    mode: "dev" | "production";
    fsId: string;
}, {}>;
export declare const FileSystemRef: import("arktype/internal/variants/object.ts").ObjectType<(In: {
    appSlug: string;
    ownerHandle?: string | undefined;
    userSlug?: string | undefined;
    mode: "dev" | "production";
    fsId: string;
}) => import("arktype").Out<{
    appSlug: string;
    mode: "dev" | "production";
    fsId: string;
    ownerHandle: string;
}>, {}>;
export type FileSystemRef = typeof FileSystemRef.infer;
export declare const PromptContextSql: import("arktype/internal/variants/object.ts").ObjectType<{
    type: "prompt.usage.sql";
    usage: {
        given: {
            prompt_tokens: number;
            completion_tokens: number;
            total_tokens: number;
        }[];
        calculated: {
            prompt_tokens: number;
            completion_tokens: number;
            total_tokens: number;
        };
    };
    fsRef?: ((In: {
        appSlug: string;
        ownerHandle?: string | undefined;
        userSlug?: string | undefined;
        mode: "dev" | "production";
        fsId: string;
    }) => import("arktype").Out<{
        appSlug: string;
        mode: "dev" | "production";
        fsId: string;
        ownerHandle: string;
    }>) | undefined;
    model?: string | undefined;
}, {}>;
export type PromptContextSql = typeof PromptContextSql.infer;
export declare const ChatContextSql: import("arktype/internal/variants/object.ts").ObjectType<{
    type: "chat.context.sql";
    userId: string;
    chatId: string;
    promptId?: string | undefined;
    fsId?: string | undefined;
    nethash: string;
    promptTokens: number;
    completionTokens: number;
    totalTokens: number;
    usage: {
        given: {
            prompt_tokens: number;
            completion_tokens: number;
            total_tokens: number;
        }[];
        calculated: {
            prompt_tokens: number;
            completion_tokens: number;
            total_tokens: number;
        };
    };
    created: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
}, {}>;
export type ChatContextSql = typeof ChatContextSql.infer;
export declare const BlockEndMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.end";
    stats: {
        toplevel: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        code: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        image: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        total: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
    };
    usage: {
        given: {
            prompt_tokens: number;
            completion_tokens: number;
            total_tokens: number;
        }[];
        calculated: {
            prompt_tokens: number;
            completion_tokens: number;
            total_tokens: number;
        };
    };
    fsRef?: ((In: {
        appSlug: string;
        ownerHandle?: string | undefined;
        userSlug?: string | undefined;
        mode: "dev" | "production";
        fsId: string;
    }) => import("arktype").Out<{
        appSlug: string;
        mode: "dev" | "production";
        fsId: string;
        ownerHandle: string;
    }>) | undefined;
}, {}>;
export declare const ToplevelBeginMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.toplevel.begin";
    sectionId: string;
}, {}>;
export declare const ToplevelLineMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    lineNr: number;
    line: string;
    type: "block.toplevel.line";
    sectionId: string;
}, {}>;
export declare const ToplevelEndMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    stats: {
        lines: number;
        bytes: number;
        cnt?: number | undefined;
    };
    type: "block.toplevel.end";
    sectionId: string;
}, {}>;
export declare const CodeBeginMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.code.begin";
    sectionId: string;
    lang: string;
    path?: string | undefined;
}, {}>;
export declare const CodeLineMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    lineNr: number;
    line: string;
    type: "block.code.line";
    sectionId: string;
    lang: string;
    path?: string | undefined;
}, {}>;
export declare const CodeEndMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    stats: {
        lines: number;
        bytes: number;
        cnt?: number | undefined;
    };
    type: "block.code.end";
    sectionId: string;
    lang: string;
    path?: string | undefined;
}, {}>;
export declare const CodeTruncatedMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.code.truncated";
    sectionId: string;
    lang: string;
    path?: string | undefined;
    reason: string;
    kind: string;
    truncatedAtLine: number;
    errorCount: number;
}, {}>;
export declare const BlockImageMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    stats: {
        lines: number;
        bytes: number;
        cnt?: number | undefined;
    };
    type: "block.image";
    sectionId: string;
    url?: string | undefined;
    uploadId?: string | undefined;
    cid?: string | undefined;
    mimeType?: string | undefined;
    size?: number | undefined;
}, {}>;
export declare const BlockStatsMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.stats";
    stats: {
        toplevel: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        code: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        image: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        total: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
    };
    usage: {
        prompt_tokens: number;
        completion_tokens: number;
        total_tokens: number;
    };
}, {}>;
export declare const ToplevelMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.toplevel.begin";
    sectionId: string;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    lineNr: number;
    line: string;
    type: "block.toplevel.line";
    sectionId: string;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    stats: {
        lines: number;
        bytes: number;
        cnt?: number | undefined;
    };
    type: "block.toplevel.end";
    sectionId: string;
}, {}>;
export declare const CodeMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.code.begin";
    sectionId: string;
    lang: string;
    path?: string | undefined;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    lineNr: number;
    line: string;
    type: "block.code.line";
    sectionId: string;
    lang: string;
    path?: string | undefined;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    stats: {
        lines: number;
        bytes: number;
        cnt?: number | undefined;
    };
    type: "block.code.end";
    sectionId: string;
    lang: string;
    path?: string | undefined;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.code.truncated";
    sectionId: string;
    lang: string;
    path?: string | undefined;
    reason: string;
    kind: string;
    truncatedAtLine: number;
    errorCount: number;
}, {}>;
export declare const LineMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    lineNr: number;
    line: string;
    type: "block.toplevel.line";
    sectionId: string;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    lineNr: number;
    line: string;
    type: "block.code.line";
    sectionId: string;
    lang: string;
    path?: string | undefined;
}, {}>;
export declare const BeginMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.toplevel.begin";
    sectionId: string;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.code.begin";
    sectionId: string;
    lang: string;
    path?: string | undefined;
}, {}>;
export declare const BlockStreamMsg: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.begin";
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.end";
    stats: {
        toplevel: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        code: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        image: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        total: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
    };
    usage: {
        given: {
            prompt_tokens: number;
            completion_tokens: number;
            total_tokens: number;
        }[];
        calculated: {
            prompt_tokens: number;
            completion_tokens: number;
            total_tokens: number;
        };
    };
    fsRef?: ((In: {
        appSlug: string;
        ownerHandle?: string | undefined;
        userSlug?: string | undefined;
        mode: "dev" | "production";
        fsId: string;
    }) => import("arktype").Out<{
        appSlug: string;
        mode: "dev" | "production";
        fsId: string;
        ownerHandle: string;
    }>) | undefined;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.toplevel.begin";
    sectionId: string;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    lineNr: number;
    line: string;
    type: "block.toplevel.line";
    sectionId: string;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    stats: {
        lines: number;
        bytes: number;
        cnt?: number | undefined;
    };
    type: "block.toplevel.end";
    sectionId: string;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.code.begin";
    sectionId: string;
    lang: string;
    path?: string | undefined;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    lineNr: number;
    line: string;
    type: "block.code.line";
    sectionId: string;
    lang: string;
    path?: string | undefined;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    stats: {
        lines: number;
        bytes: number;
        cnt?: number | undefined;
    };
    type: "block.code.end";
    sectionId: string;
    lang: string;
    path?: string | undefined;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.code.truncated";
    sectionId: string;
    lang: string;
    path?: string | undefined;
    reason: string;
    kind: string;
    truncatedAtLine: number;
    errorCount: number;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    stats: {
        lines: number;
        bytes: number;
        cnt?: number | undefined;
    };
    type: "block.image";
    sectionId: string;
    url?: string | undefined;
    uploadId?: string | undefined;
    cid?: string | undefined;
    mimeType?: string | undefined;
    size?: number | undefined;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.stats";
    stats: {
        toplevel: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        code: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        image: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        total: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
    };
    usage: {
        prompt_tokens: number;
        completion_tokens: number;
        total_tokens: number;
    };
}, {}>;
export declare const BlockMsgs: import("arktype/internal/variants/object.ts").ObjectType<{
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.begin";
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.end";
    stats: {
        toplevel: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        code: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        image: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        total: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
    };
    usage: {
        given: {
            prompt_tokens: number;
            completion_tokens: number;
            total_tokens: number;
        }[];
        calculated: {
            prompt_tokens: number;
            completion_tokens: number;
            total_tokens: number;
        };
    };
    fsRef?: ((In: {
        appSlug: string;
        ownerHandle?: string | undefined;
        userSlug?: string | undefined;
        mode: "dev" | "production";
        fsId: string;
    }) => import("arktype").Out<{
        appSlug: string;
        mode: "dev" | "production";
        fsId: string;
        ownerHandle: string;
    }>) | undefined;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.toplevel.begin";
    sectionId: string;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    lineNr: number;
    line: string;
    type: "block.toplevel.line";
    sectionId: string;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    stats: {
        lines: number;
        bytes: number;
        cnt?: number | undefined;
    };
    type: "block.toplevel.end";
    sectionId: string;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.code.begin";
    sectionId: string;
    lang: string;
    path?: string | undefined;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    lineNr: number;
    line: string;
    type: "block.code.line";
    sectionId: string;
    lang: string;
    path?: string | undefined;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    stats: {
        lines: number;
        bytes: number;
        cnt?: number | undefined;
    };
    type: "block.code.end";
    sectionId: string;
    lang: string;
    path?: string | undefined;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.code.truncated";
    sectionId: string;
    lang: string;
    path?: string | undefined;
    reason: string;
    kind: string;
    truncatedAtLine: number;
    errorCount: number;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    stats: {
        lines: number;
        bytes: number;
        cnt?: number | undefined;
    };
    type: "block.image";
    sectionId: string;
    url?: string | undefined;
    uploadId?: string | undefined;
    cid?: string | undefined;
    mimeType?: string | undefined;
    size?: number | undefined;
} | {
    blockId: string;
    streamId: string;
    seq: number;
    blockNr: number;
    timestamp: Date | ((In: string) => import("arktype/internal/attributes.ts").To<Date>);
    type: "block.stats";
    stats: {
        toplevel: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        code: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        image: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
        total: {
            lines: number;
            bytes: number;
            cnt?: number | undefined;
        };
    };
    usage: {
        prompt_tokens: number;
        completion_tokens: number;
        total_tokens: number;
    };
}, {}>;
export type BlockBeginMsg = typeof BlockBeginMsg.infer;
export type BlockEndMsg = typeof BlockEndMsg.infer;
export type BlockStatsMsg = typeof BlockStatsMsg.infer;
export type ToplevelBeginMsg = typeof ToplevelBeginMsg.infer;
export type ToplevelLineMsg = typeof ToplevelLineMsg.infer;
export type ToplevelEndMsg = typeof ToplevelEndMsg.infer;
export type CodeBeginMsg = typeof CodeBeginMsg.infer;
export type CodeLineMsg = typeof CodeLineMsg.infer;
export type CodeEndMsg = typeof CodeEndMsg.infer;
export type CodeTruncatedMsg = typeof CodeTruncatedMsg.infer;
export type BlockImageMsg = typeof BlockImageMsg.infer;
export type BlockStreamMsg = typeof BlockStreamMsg.infer;
export type ToplevelMsg = typeof ToplevelMsg.infer;
export type CodeMsg = typeof CodeMsg.infer;
export type BlockMsgs = typeof BlockMsgs.infer;
export type LineMsg = typeof LineMsg.infer;
export type BeginMsg = typeof BeginMsg.infer;
export declare const isBlockBegin: (msg: unknown, streamId?: string) => msg is BlockBeginMsg;
export declare const isBlockEnd: (msg: unknown, streamId?: string) => msg is BlockEndMsg;
export declare const isBlockStats: (msg: unknown, streamId?: string) => msg is BlockStatsMsg;
export declare const isToplevelBegin: (msg: unknown, streamId?: string) => msg is ToplevelBeginMsg;
export declare const isToplevelLine: (msg: unknown, streamId?: string) => msg is ToplevelLineMsg;
export declare const isToplevelEnd: (msg: unknown, streamId?: string) => msg is ToplevelEndMsg;
export declare const isCodeBegin: (msg: unknown, streamId?: string) => msg is CodeBeginMsg;
export declare const isCodeLine: (msg: unknown, streamId?: string) => msg is CodeLineMsg;
export declare const isCodeEnd: (msg: unknown, streamId?: string) => msg is CodeEndMsg;
export declare const isCodeTruncated: (msg: unknown, streamId?: string) => msg is CodeTruncatedMsg;
export declare const isBlockImage: (msg: unknown, streamId?: string) => msg is BlockImageMsg;
export declare const isBlockStreamMsg: (msg: unknown, streamId?: string) => msg is BlockStreamMsg;
export declare function createBlockStream(streamId: string, innerStreamId: string, createId: () => string): TransformStream<LineStreamMsg | DeltaStreamMsg | StatsCollectMsg, BlockStreamMsg>;
export declare function createSectionsStream(filterStreamId: string, createId: () => string): TransformStream<DeltaStreamMsg, BlockStreamMsg>;