import { Send } from "../constants.js"; import { RunnableCallable } from "../utils.js"; import { Runnable, RunnableConfig, RunnableLike } from "@langchain/core/runnables"; //#region src/pregel/write.d.ts /** * Mapping of write channels to Runnables that return the value to be written, * or None to skip writing. */ declare class ChannelWrite extends RunnableCallable { writes: Array; constructor(writes: Array, tags?: string[]); _write(input: unknown, config: RunnableConfig): Promise; static doWrite(config: RunnableConfig, writes: (ChannelWriteEntry | ChannelWriteTupleEntry | Send)[]): Promise; static isWriter(runnable: RunnableLike): runnable is ChannelWrite; static registerWriter(runnable: T): T; } interface ChannelWriteEntry { channel: string; value: unknown; skipNone?: boolean; mapper?: Runnable; } interface ChannelWriteTupleEntry { value: unknown; mapper: Runnable; } //#endregion export { ChannelWrite }; //# sourceMappingURL=write.d.ts.map