Class CodeExecution

src/kernels/execution/codeExecution.ts:37–219

 * Further details here https://github.com/microsoft/vscode-jupyter/issues/232 & https://github.com/jupyter/jupyter_client/issues/297
 */
export class CodeExecution implements ICodeExecution, IDisposable {
    public readonly type = 'code';
    public get done(): Promise<void> {
        return this._done.promise;
    }
    public get result(): Promise<void> {
        return this._done.promise;
    }
    private readonly _onDidEmitOutput = new EventEmitter<NotebookCellOutput>();
    public readonly onDidEmitOutput = this._onDidEmitOutput.event;
    private readonly _onRequestSent = new EventEmitter<void>();
    public readonly onRequestSent = this._onRequestSent.event;
    private readonly _onRequestAcknowledge = new EventEmitter<void>();
    public readonly onRequestAcknowledged = this._onRequestAcknowledge.event;
    private readonly _done = createDeferred<void>();
    private started?: boolean;

    private _completed?: boolean;
    private cancelHandled = false;
    private disposed?: boolean;
    private request: Kernel.IShellFuture<KernelMessage.IExecuteRequestMsg, KernelMessage.IExecuteReplyMsg> | undefined;
    private readonly disposables: IDisposable[] = [];
    private session?: IKernelSession;
    private cancelRequested?: boolean;
    public readonly executionId: string;
    private constructor(
        public readonly code: string,
        public readonly extensionId: string
    ) {
        let executionId = extensionIdsPerExtension.get(extensionId) || 0;
        executionId += 1;
        extensionIdsPerExtension.set(extensionId, executionId);
        this.executionId = `${extensionId}-${executionId}`;
        this.disposables.push(this._onDidEmitOutput);
    }

    public static fromCode(code: string, extensionId: string) {
        return new CodeExecution(code, extensionId);
    }
    public async start(session: IKernelSession) {
        this.session = session;
        if (this.cancelHandled) {
            traceExecMessage(this.extensionId, this.executionId, 'Not starting as it was cancelled');
            return;
        }
        traceExecMessage(this.extensionId, this.executionId, 'Start Code execution');
        logger.ci(`Code Exec contents ${this.code.substring(0, 50)}...`);
        if (!session.kernel || session.kernel.isDisposed || session.isDisposed) {
            this._done.reject(new SessionDisposedError());
            return;
        }

        if (this.started) {
            traceExecMessage(
                this.extensionId,
                this.executionId,
                'Code has already been started yet CodeExecution.Start invoked again'
            );