import type { Observable } from './types/outputs/Observable.js';
/**
 * Creates an observable using fn's logic.
 * @param fn subscriber function
 *
 * @since 1.0.0
 */
export declare function observable$<D>(fn: SubscriberFn<D>): Observable<D>;
export interface SubscriberObserver<in D = unknown> {
    /**
     * Emits given value
     * @param data
     */
    readonly next: (data: D) => void;
    /**
     * Emits given error
     * @param err
     */
    readonly error: (err: unknown) => void;
    /**
     * Completes the observable and closes all subscriptions
     */
    readonly complete: () => void;
}
export type SubscriberFn<out D> = (observer: SubscriberObserver<D>, signal: AbortSignal) => Promise<void> | void;