import { Observable, BehaviorSubject, Subject } from 'rxjs';
import { IDataSource } from './IDataSource';
import { IQueryExecutionResult, IQueryExecutionGroupResult, IFilter, ISort, IAggregate, IGroup, IQueryCriteria } from './models';
import { IDataSourceOptions, IResolveCommandModelEvent } from '../public-api';
import { IDataSourceValidationError } from './IDataSourceValidationError';
import { IDataSourceNotifyMessage } from './IDataSourceNotifyMessage';
import { IDataSourceCommandStarted } from './IDataSourceCommandStarted';
export declare class DataSource<TModel> implements IDataSource<TModel> {
    options: IDataSourceOptions<TModel>;
    data: IQueryExecutionResult<TModel> & IQueryExecutionGroupResult<TModel>;
    protected _dataSubject: BehaviorSubject<IQueryExecutionResult<TModel> & IQueryExecutionGroupResult<TModel>>;
    protected _loadingSubject: BehaviorSubject<boolean>;
    protected _validationSubject: Subject<IDataSourceValidationError>;
    protected _commandStartedSubject: Subject<IDataSourceCommandStarted>;
    protected _notifyMessageSubject: Subject<IDataSourceNotifyMessage>;
    protected _data$: Observable<IQueryExecutionResult<TModel> & IQueryExecutionGroupResult<TModel>>;
    protected _loading$: Observable<boolean>;
    protected _validationError$: Observable<IDataSourceValidationError>;
    protected _notifyMessage$: Observable<IDataSourceNotifyMessage>;
    protected _commandStarted$: Observable<IDataSourceCommandStarted>;
    protected _criteria: IQueryCriteria;
    readonly data$: Observable<IQueryExecutionResult<TModel> & IQueryExecutionGroupResult<TModel>>;
    readonly loading$: Observable<boolean>;
    readonly validationError$: Observable<IDataSourceValidationError>;
    readonly commandStarted$: Observable<IDataSourceCommandStarted>;
    readonly notifyMessage$: Observable<IDataSourceNotifyMessage>;
    constructor(options: IDataSourceOptions<TModel>);
    clear(): void;
    updateData(value: IQueryExecutionResult<TModel> & IQueryExecutionGroupResult<TModel>): void;
    replaceDataWithArray(items: TModel[]): void;
    replaceDataWithSingle(item: TModel): void;
    protected _initCriteria(): void;
    resolveIdField<TKeyType extends any>(model: TModel): TKeyType;
    resolveCommandModelByName<T extends any>(event: IResolveCommandModelEvent<TModel>): Observable<T>;
    executeCommandByName<TCommand, TResult>(name: string, command: TCommand): Observable<TResult>;
    private _query;
    query<TQuery extends IQueryCriteria>(query: TQuery): import("rxjs").Subscription;
    excuteQuery<TQuery extends IQueryCriteria>(query: TQuery): Observable<IQueryExecutionGroupResult<TModel> & IQueryExecutionGroupResult<TModel>>;
    refresh(): import("rxjs").Subscription;
    sorts: ISort[];
    filters: IFilter[];
    groups: IGroup[];
    aggregates: IAggregate[];
    pageSize: number;
    page: number;
}