import { Observable } from 'rxjs/Observable';
import 'rxjs/add/observable/of';
import 'rxjs/add/observable/from';
import 'rxjs/add/operator/concatMap';
import 'rxjs/add/operator/mergeMap';
import 'rxjs/add/operator/take';
import 'rxjs/add/operator/map';
import 'rxjs/add/operator/mapTo';
import 'rxjs/add/operator/scan';
import 'rxjs/add/operator/toPromise';
import { ValueOrResolver, PartialValueOrResolver } from './common';
import { StoreOptions, ActionOptions } from './common';
import { IReactiveStore } from './interfaces';
import './add/operator/all';
export declare const latestUpdatedKey = "__latest__";
export declare class ReactiveStore<T> implements IReactiveStore<T> {
    private _dispatcher$;
    private _provider$;
    private _concurrent;
    private _loopType;
    private _output;
    private _ngZone;
    private _testing;
    private _useFreeze;
    private _reduxApplyMiddleware;
    private _reduxMiddlewares;
    private _useReduxDevToolsExtension;
    private _initialState;
    private _reduxStore;
    constructor(initialState: T, options?: StoreOptions);
    private createStore();
    private effectAfterReduced(state);
    private applyEffectors();
    private createReduxStore();
    /**
     * To set a new value to the specified key.
     */
    setter<K extends keyof T>(key: K, value: ValueOrResolver<T, K>, options?: ActionOptions): Promise<void>;
    /**
     * To set a new partial value to the specified key. Partial value will be merged.
     */
    setterPartial<K extends keyof T>(key: K, value: PartialValueOrResolver<T, K>, options?: ActionOptions): Promise<void>;
    /**
     * To reset the value under the specified key.
     */
    resetter<K extends keyof T>(key: K, options?: ActionOptions): Promise<void>;
    /**
     * To get all of the current state as Observable.
     */
    getter(): Observable<T>;
    /**
     * To get all of the current state as Promise.
     */
    getterAsPromise(): Promise<T>;
    /**
     * To reset to the initial state just for testing.
     */
    forceResetForTesting(): Promise<void> | never;
    /**
     * To complete and stop streams just for testing.
     */
    forceCompleteForTesting(): Promise<void> | never;
    /**
     * To get initial state synchronously.
     */
    readonly initialState: T;
    /**
     * To get current state synchronously.
     */
    readonly currentState: T;
}