import type { BlockStreamingCoalescing } from "./block-streaming.js";

/** Coalesces many streaming reply fragments into fewer outbound payloads. */

export type BlockReplyCoalescer = {

type BlockReplyCoalescer = {

enqueue: (payload: ReplyPayload) => void;

flush: (options?: { force?: boolean }) => Promise<void>;

hasBuffered: () => boolean;

};

/** Optional buffering strategy used before payloads enter block delivery. */

export type BlockReplyBuffer = {

type BlockReplyBuffer = {

shouldBuffer: (payload: ReplyPayload) => boolean;

onEnqueue?: (payload: ReplyPayload) => void;

finalize?: (payload: ReplyPayload) => ReplyPayload;

flushOnEnqueue?: boolean;

};

export type BlockStreamingChunking = {

type BlockStreamingChunking = {

minChars: number;

maxChars: number;

breakPreference: "paragraph" | "newline" | "sentence";

import type { DeliveryContext } from "../../utils/delivery-context.types.js";

import { resolveSourceReplyDeliveryMode } from "./source-reply-delivery-mode.js";

export type CompletionChatType = ChatType | "unknown";

type CompletionChatType = ChatType | "unknown";

export type CompletionDeliverySessionEntry = {

type CompletionDeliverySessionEntry = {

chatType?: string | null;

origin?: { chatType?: string | null } | null;

};