import { StreamState, Stream, StreamReaderWriter } from '@ceramicnetwork/common';
import { Observable } from 'rxjs';
import { HandlersMap } from '../handlers-map.js';
export declare function streamFromState<T extends Stream>(context: StreamReaderWriter, handlersMap: HandlersMap, state: StreamState, update$?: (init: StreamState) => Observable<StreamState>): T;
//# sourceMappingURL=stream-from-state.d.ts.map