import { type $Callback } from "@dweb-browser/helper/createSignal.ts";
import { BasePlugin } from "../components/base/base.plugin.js";
type $Transform<T, R> = (value: T) => R;
/**
 * 提供了一个状态的读取与更新的功能
 */
export declare class StateObserver<RAW, STATE> {
    private plugin;
    private fetcher;
    private coder;
    private buildWsUrl;
    private _ipc;
    constructor(plugin: BasePlugin, fetcher: () => Promise<RAW>, coder: {
        decode: $Transform<RAW, STATE>;
        encode: $Transform<STATE, RAW>;
    }, buildWsUrl?: (ws_url: URL) => Promise<URL | void>);
    private ws?;
    /**监听状态变化 */
    jsonlines(options?: {
        signal?: AbortSignal;
    }): Promise<AsyncGenerator<Awaited<STATE>, void, unknown>>;
    pullMessage(wsUrl: string, controller: ReadableStreamDefaultController<string>): void;
    stopObserve(): void;
    private _currentState?;
    /**
     * 当前的状态集合
     */
    get currentState(): STATE | undefined;
    set currentState(state: STATE | undefined);
    private _signalCurrentStateChange;
    readonly onChange: (cb: $Callback<[STATE]>) => import("@dweb-browser/helper/createSignal.ts").$OffListener;
    /**
     * 获取当前状态栏的完整信息
     * @returns
     */
    getState(force_update?: boolean): Promise<STATE>;
    /**
     * 刷新获取有关状态栏当前状态的信息。
     */
    private _updateCurrentState;
}
export interface $Coder<RAW, STATE> {
    decode: $Transform<RAW, STATE>;
    encode: $Transform<STATE, RAW>;
}
export {};
//# sourceMappingURL=StateObserver.d.ts.map