import { AbstractStreamingSyncImplementation, AbstractStreamingSyncImplementationOptions, DiagnosticsEvent, LockOptions } from '@powersync/shared-internals';
export interface WebStreamingSyncImplementationOptions extends AbstractStreamingSyncImplementationOptions {
    sync?: {
        worker?: string | URL | (() => SharedWorker);
    };
}
export declare class WebStreamingSyncImplementation extends AbstractStreamingSyncImplementation {
    private diagnosticsChannel?;
    constructor(options: WebStreamingSyncImplementationOptions);
    /**
     * Broadcasts a core diagnostics event on a same-origin channel for diagnostics tooling to consume.
     * The channel reaches the page even when sync runs in a shared worker.
     */
    protected emitDiagnostics(event: DiagnosticsEvent): void;
    dispose(): Promise<void>;
    get webOptions(): WebStreamingSyncImplementationOptions;
    obtainLock<T>(lockOptions: LockOptions<T>): Promise<T>;
}