Genotype API Documentation - v0.1.0
    Preparing search index...

    Variable StreamUtilsConst

    StreamUtils: {
        readLines: (
            stream: ReadableStream<Uint8Array<ArrayBufferLike>>,
            encoding?: "utf8" | "binary" | "ascii",
        ) => AsyncIterable<string>;
        processBuffer: (buffer: string) => LineProcessingResult;
        pipe: <T, U>(
            input: AsyncIterable<T>,
            transform: (item: T, index: number) => U | Promise<U>,
        ) => AsyncIterable<U>;
        processChunks: (
            stream: ReadableStream<Uint8Array<ArrayBufferLike>>,
        ) => AsyncIterable<StreamChunk & { stats: StreamStats }>;
        batchLines: (
            lines: AsyncIterable<string>,
            batchSize?: number,
        ) => AsyncIterable<string[]>;
    } = ...

    Check memory usage and throw error if excessive

    Type Declaration

    • readLines: (
          stream: ReadableStream<Uint8Array<ArrayBufferLike>>,
          encoding?: "utf8" | "binary" | "ascii",
      ) => AsyncIterable<string>
    • processBuffer: (buffer: string) => LineProcessingResult
    • pipe: <T, U>(
          input: AsyncIterable<T>,
          transform: (item: T, index: number) => U | Promise<U>,
      ) => AsyncIterable<U>
    • processChunks: (
          stream: ReadableStream<Uint8Array<ArrayBufferLike>>,
      ) => AsyncIterable<StreamChunk & { stats: StreamStats }>
    • batchLines: (lines: AsyncIterable<string>, batchSize?: number) => AsyncIterable<string[]>

    Settings

    Member Visibility