@s2-dev/streamstore - v0.18.1
    Preparing search index...

    Interface AcksStream

    Stream of append acknowledgements used by AppendSession.

    interface AcksStream {
        locked: boolean;
        "[asyncIterator]"(): AsyncIterator<AppendAck, any, any>;
        cancel(reason?: any): Promise<void>;
        getReader(options: { mode: "byob" }): ReadableStreamBYOBReader;
        getReader(): ReadableStreamDefaultReader<AppendAck>;
        getReader(
            options?: ReadableStreamGetReaderOptions,
        ): ReadableStreamReader<AppendAck>;
        pipeThrough<T>(
            transform: ReadableWritablePair<T, AppendAck>,
            options?: StreamPipeOptions,
        ): ReadableStream<T>;
        pipeTo(
            destination: WritableStream<AppendAck>,
            options?: StreamPipeOptions,
        ): Promise<void>;
        tee(): [ReadableStream<AppendAck>, ReadableStream<AppendAck>];
    }

    Hierarchy

    Index

    Properties

    locked

    Methods

    [asyncIterator] cancel getReader pipeThrough pipeTo tee

    Properties

    locked: boolean

    MDN Reference

    Methods

    • Returns AsyncIterator<AppendAck, any, any>

    • MDN Reference

      Parameters

      • Optionalreason: any

      Returns Promise<void>

    • MDN Reference

      Parameters

      • options: { mode: "byob" }

      Returns ReadableStreamBYOBReader

    • Returns ReadableStreamDefaultReader<AppendAck>

    • Parameters

      • Optionaloptions: ReadableStreamGetReaderOptions

      Returns ReadableStreamReader<AppendAck>

    • MDN Reference

      Type Parameters

      • T

      Parameters

      • transform: ReadableWritablePair<T, AppendAck>
      • Optionaloptions: StreamPipeOptions

      Returns ReadableStream<T>

    • MDN Reference

      Parameters

      • destination: WritableStream<AppendAck>
      • Optionaloptions: StreamPipeOptions

      Returns Promise<void>

    Settings

    Member Visibility

    On This Page

    Properties
    Methods