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