import { BehaviorSubject, Subscription, Observable } from 'rxjs';
export interface Ring<D> {
    input: BehaviorSubject<D>;
    output: BehaviorSubject<D>;
    subscribe(): Subscription;
}
export interface ChainArgs<D> {
    isAlive: Observable<boolean>;
    source: Observable<D[]>;
    rings: Ring<D[]>[];
}
export declare class Chain<D> {
    private readonly subscriptions;
    private readonly initiator;
    private readonly rings;
    private readonly source;
    constructor({ isAlive, source, rings }: ChainArgs<D>);
    private init;
    private destroy;
}