Interface FluxResultObserver<T>

Observes results of a flux query.

interface FluxResultObserver<T> {
    useCancellable?: (cancellable: Cancellable) => void;
    useResume?: (resume: () => void) => void;
    complete(): void;
    error(error: Error): void;
    next(row: T, tableMeta: FluxTableMetaData): boolean | void;
}

Type Parameters

  • T

Properties

useCancellable? useResume?

Methods

complete error next

Properties

OptionaluseCancellable

useCancellable?: (cancellable: Cancellable) => void

Setups cancellable that can abort flux result processing.

OptionaluseResume

useResume?: (resume: () => void) => void

Setups a callback that resumes reading of next data, it is called whenever FluxResultObserver.next returns false.

Type declaration

    • (resume: () => void): void

    • Parameters

      • resume: () => void

        a function that will resume reading of next data when called

      Returns void

Methods

complete

error

next

Settings

Member Visibility

On This Page

Properties
Methods