import { StreamSplitter } from "https://deno.land/x/earthstar@v10.0.0-alpha.4/src/streams/stream_utils.ts";
Constructors
new
StreamSplitter(getKey: (chunk: ChunkType) => string | undefined)Properties
private
getKey: (chunk: ChunkType) => string | undefinedprivate
incomingCloner: CloneStream<ChunkType>private
transforms: Map<string, TransformStream<ChunkType, ChunkType>>Methods
getReadable(key: string): ReadableStream<ChunkType>