Function createObservable

src/platform/common/process/proc.node.ts:285–304

()

}

export function createObservable<T>() {
    const onDidChange = new EventEmitter<T>();
    const promise = createDeferred<void>();
    // No dangling promises.
    promise.promise.catch(noop);
    return {
        get onDidChange() {
            return onDidChange.event;
        },
        get done() {
            return promise.promise;
        },
        resolve: promise.resolve.bind(promise),
        reject: promise.reject.bind(promise),
        fire: onDidChange.fire.bind(onDidChange),
        dispose: () => {
            onDidChange.dispose();
        }
    };
}