export interface NextObserver<T> {
    closed?: boolean;
    next(value: T): void;
    error?(error: unknown): void;
    complete?(): void;