@qualithm/arrow-flight-sql-js - v0.4.3
    Preparing search index...

    Type Alias SubscriptionHandle<T>

    SubscriptionHandle: {
        batchesReceived: number;
        connected: boolean;
        id: string;
        next: () => Promise<IteratorResult<T>>;
        reconnectCount: number;
        unsubscribe: () => Promise<void>;
    } & AsyncIterable<T>

    Handle for an active subscription with control methods

    Type Parameters

    • T = RecordBatch

    Type Declaration

    • ReadonlybatchesReceived: number

      Number of batches received

    • Readonlyconnected: boolean

      Whether the subscription is currently connected

    • Readonlyid: string

      Unique ID for this subscription

    • next: () => Promise<IteratorResult<T>>

      Manually get the next batch

    • ReadonlyreconnectCount: number

      Number of reconnection attempts

    • unsubscribe: () => Promise<void>

      Unsubscribe and close the connection

    Settings

    Member Visibility