import { Promisable } from "type-fest";
import { Status } from "../utils/status.js";
export declare type OutgoingTextRequestDefault
= {
readonly parameters: P;
} & OutgoingTextContainer;
export declare type OutgoingTextRequest
= {
readonly parameters: P;
readonly contentType: C;
} & OutgoingTextContainer;
export declare type OutgoingTextResponseDefault = {
readonly status: S;
readonly parameters: P;
} & OutgoingTextContainer;
export declare type OutgoingTextResponse = {
readonly status: S;
readonly parameters: P;
readonly contentType: C;
} & OutgoingTextContainer;
export declare type IncomingTextRequest
= {
readonly parameters: P;
readonly contentType: C;
} & IncomingTextContainer;
export declare type IncomingTextResponse = {
readonly status: S;
readonly parameters: P;
readonly contentType: C;
} & IncomingTextContainer;
export declare type OutgoingTextContainer = {
stream(signal?: AbortSignal): AsyncIterable;
} | {
value(): Promisable;
} | {
lines(signal?: AbortSignal): AsyncIterable;
};
export declare type IncomingTextContainer = {
stream(signal?: AbortSignal): AsyncIterable;
} & {
value(): Promisable;
} & {
lines(signal?: AbortSignal): AsyncIterable;
};
export declare function serializeOutgoingTextContainer(container: OutgoingTextContainer, mapError?: (error: Error) => Error): (signal?: AbortSignal | undefined) => AsyncIterable;
export declare function deserializeIncomingTextContainer(stream: (signal?: AbortSignal) => AsyncIterable, mapError?: (error: Error) => Error): {
stream: (signal?: AbortSignal | undefined) => AsyncIterable;
value(): Promise;
lines(signal?: AbortSignal | undefined): AsyncIterable;
};
export declare function serializeTextValue(value: Promisable): AsyncIterable;
export declare function serializeTextLines(lines: AsyncIterable): AsyncIterable;
export declare function deserializeTextValue(stream: (signal?: AbortSignal) => AsyncIterable): Promise;
export declare function deserializeTextLines(stream: (signal?: AbortSignal) => AsyncIterable, signal?: AbortSignal): AsyncIterable;