import { L as StreamChannelRef, a as ISdk, b as ChannelItem, r as Channel, y as ChannelDirection } from "./types-CEcg039t.cjs"; import { IStream } from "./stream.cjs"; //#region src/utils.d.ts /** * Type guard that checks if a value is a {@link StreamChannelRef}. * * @param value - Value to check. * @returns `true` if the value is a valid `StreamChannelRef`. */ declare const isChannelRef: (value: unknown) => value is StreamChannelRef; /** * Recursively extract all {@link StreamChannelRef} values from a JSON-like * input, returning each match paired with its dotted/bracketed path. Mirrors * the Rust SDK's `extract_channel_refs`. * * @param data - Arbitrary JSON-like value. * @returns Array of `[path, ref]` tuples. Empty when no refs are found. */ declare const extractChannelRefs: (data: unknown) => Array<[string, StreamChannelRef]>; //#endregion //#region src/helpers.d.ts /** * Create a streaming channel pair for worker-to-worker data transfer. * * Free-function form of the previous `ISdk.createChannel` instance method. */ declare function createChannel(iii: ISdk, bufferSize?: number): Promise; /** * Register a custom stream implementation by wiring its 5 callable methods * to `stream::get/set/delete/list/list_groups`. * * Free-function form of the previous `ISdk.createStream` instance method. */ declare function createStream(iii: ISdk, streamName: string, stream: IStream): void; //#endregion export { ChannelDirection, ChannelItem, createChannel, createStream, extractChannelRefs, isChannelRef }; //# sourceMappingURL=helpers.d.cts.map