import { Observable } from 'kefir'; import { PreloadedStoreState, StoreOptions, StoreSelectorCallback, StoreStateMap } from './types'; import { StoreRuntime, StoreBoundState, StoreMiddlewareInput, StoreReducersInput } from './store-runtime'; import { StoreStreamingSelector } from './utils/streaming-selectors/create-selector'; export type { StoreOptions } from './types'; /** * Kefir/observable Store variant. Its selectors return Kefir streams when * called and keep .select/.effect escape hatches for tests and sagas. */ export declare class StreamingStore = StoreReducersInput> extends StoreRuntime { private streamState; /** * Create a streaming Store with app-owned reducers and middlewares. * Throws if any reducer uses a package-reserved internal key. */ constructor(reducersMap?: TReducers & StoreReducersInput, middleware?: StoreMiddlewareInput, options?: StoreOptions); init(initialState?: PreloadedStoreState): () => void; createSelector(selectorFunc: StoreSelectorCallback>): StoreStreamingSelector>; getStreamState(): Observable, any>; dispose(): void; } //# sourceMappingURL=streaming-store.d.ts.map