import type { Observable } from 'rxjs';
/**
 * Subscribes to an observable and returns a promise that resolves when complete.
 * Useful for streaming processing where you want to handle each item as it arrives.
 */
export declare function subscribeToObservable<T>(observable: Observable<T>, onNext: (item: T) => void): Promise<void>;