import { Subscriber, Subscription } from "../_core";
import { Transaction } from "../_tx";
import { Observable } from "../Observable";
export declare function runEffects<T>(eff: Eff<T>, observable: Observable<T>): void;
export declare class Eff<T> implements Subscriber<T> {
    private subs;
    setSubscription(subscription: Subscription): void;
    dispose(): void;
    next(tx: Transaction, val: T): void;
    error(tx: Transaction, err: Error): void;
    end(tx: Transaction): void;
}