import { Cancellable } from '../results/Cancellable' ; import { FluxTableMetaData } from './FluxTableMetaData' ; /**
 * Observes results of a flux query.
 */ export interface FluxResultObserver < T > { /**
     * Inform about a next record in a table.
     */ next ( row , tableMeta ) : void ; /**
     * Signalizes processing error.
     */ error ( error ) : void ; /**
     * Signalizes completition.
     */ complete ( ) : void ; /**
     * Setups cancellable that can abort flux result processing.
     */ useCancellable ? : ( cancellable : Cancellable ) => void ; }