<commit_before>declare interface Subscription {
    // Cancels the subscription
    unsubscribe(): void;
}

declare interface Observer {

    // Sends the next value in the sequence
    next(value: any): void;

    // Sends the sequence error
    error(errorValue: any): void;

    // Sends the sequence completion value
    complete(completeValue: any): void;
}

declare interface SubscriptionObserver {

    // Sends the next value in the sequence
    next(value: any): void;

    // Sends the sequence error
    error(errorValue: any): void;

    // Sends the sequence completion value
    complete(completeValue: any): void;
}

declare function SubscriberFunction(observer: SubscriptionObserver) : Function | Subscription;

declare class Observable {
    constructor(subscriber: SubscriberFunction): void;

    // Subscribes to the sequence
    subscribe(observer: Observer): Subscription;

    // Subscribes to the sequence with a callback, returning a promise
    forEach(onNext: Function): Promise<any>;

    // Converts items to an Observable
    static of(...items: Array<any>): Observable;

    // Converts an observable or iterable to an Observable
    static from(observable: Observable): Observable;
}
<commit_msg>chore(flow): update interface for Observable<commit_after>declare interface Subscription {
    // Cancels the subscription
    unsubscribe(): void;

    // A boolean value indicating whether the subscription is closed
    closed: Boolean;
}

declare interface Observer {

    // Receives the subscription object when `subscribe` is called
    start?: (subscription: Subscription) => void;

    // Sends the next value in the sequence
    next?: (value: any) => void;

    // Sends the sequence error
    error?: (errorValue: any) => void;

    // Sends the sequence completion value
    complete?: (completeValue: any) => void;
}

declare interface SubscriptionObserver {

    // Sends the next value in the sequence
    next(value: any): void;

    // Sends the sequence error
    error(errorValue: any): void;

    // Sends the sequence completion value
    complete(completeValue: any): void;

    // A boolean value indicating whether the subscription is closed
    closed: Boolean;
}

declare function SubscriberFunction(observer: SubscriptionObserver) : Function | Subscription;

declare class Observable {
    constructor(subscriber: SubscriberFunction): void;

    // Subscribes to the sequence
    subscribe(observer: Observer): Subscription;

    // Subscribes to the sequence with a callback, returning a promise
    forEach(onNext: Function): Promise<any>;

    // Converts items to an Observable
    static of(...items: Array<any>): Observable;

    // Converts an observable or iterable to an Observable
    static from(observable: Observable): Observable;
}

{'fraction_non_alphanumeric': 0.08714285714285715, 'fraction_numerical': 0.0, 'mean_word_length': 3.517741935483871, 'pattern_counts': {'":': 0, '<': 7, '<?xml version=': 0, '>': 11, 'https://': 0, 'lorem ipsum': 0, 'www.': 0, 'xml': 0}, 'pii_count': 0, 'substrings_counts': 0, 'word_list_counts': {'cursed_substrings.json': 0, 'profanity_word_list.json': 0, 'sexual_word_list.json': 0, 'zh_pornsignals.json': 0}}
{'dir': 'git-commits-cleaned', 'id': '6114986', 'n_tokens_mistral': 742, 'n_tokens_neox': 695, 'n_words': 275}