import MillenniumDBError from './millenniumdb-error';
import { ResponseHandlerObserver, QueryPreamble } from './response-handler';
import { ResultObserver } from './result';
/**
 * StreamObserver handles the stream of data coming from the server. It stores the result until the subscription is established
 */
declare class QueryObserver implements ResponseHandlerObserver {
    private _variables;
    private _queryPreamble;
    private _variableToIndex;
    private _error;
    private _summary;
    private _resultObserver;
    private readonly _pendingRecords;
    /**
     * This constructor should not be called directly
     */
    constructor();
    onVariables(variables: Array<string>, queryPreamble: QueryPreamble): void;
    onRecord(values: Array<any>): void;
    onSuccess(summary: any): void;
    onError(error: MillenniumDBError): void;
    subscribe(resultObserver: ResultObserver): void;
    unsubscribe(): void;
}
export default QueryObserver;