Function executeSilentlyAndEmitOutput

src/kernels/helpers.ts:750–824

(
    kernelConnection: Kernel.IKernelConnection,
    code: string,
    onStarted: () => void,
    onOutput: (output: NotebookCellOutput) => void
)

}

export function executeSilentlyAndEmitOutput(
    kernelConnection: Kernel.IKernelConnection,
    code: string,
    onStarted: () => void,
    onOutput: (output: NotebookCellOutput) => void
) {
    code = code.replace(/\r\n/g, '\n');

    const request = kernelConnection.requestExecute(
        {
            code,
            silent: false,
            stop_on_error: false,
            allow_stdin: false,
            store_history: false
        },
        true
    );
    const started = once(onStarted);
    request.onIOPub = (msg) => {
        started();
        if (jupyterLab.KernelMessage.isStreamMsg(msg)) {
            onOutput(
                cellOutputToVSCCellOutput({
                    output_type: 'stream',
                    name: msg.content.name,
                    text: msg.content.text
                })
            );
        } else if (jupyterLab.KernelMessage.isExecuteResultMsg(msg)) {
            onOutput(
                cellOutputToVSCCellOutput({
                    output_type: 'execute_result',
                    data: msg.content.data,
                    metadata: msg.content.metadata,
                    // eslint-disable-next-line @typescript-eslint/no-explicit-any
                    transient: msg.content.transient as any, // NOSONAR
                    execution_count: msg.content.execution_count
                })
            );
        } else if (jupyterLab.KernelMessage.isDisplayDataMsg(msg)) {
            onOutput(
                cellOutputToVSCCellOutput({
                    output_type: 'display_data',
                    data: handleTensorBoardDisplayDataOutput(msg.content.data),
                    metadata: msg.content.metadata,
                    transient: msg.content.transient
                })
            );
        } else if (jupyterLab.KernelMessage.isUpdateDisplayDataMsg(msg)) {
            onOutput(
                cellOutputToVSCCellOutput({
                    output_type: 'display_data',
                    data: handleTensorBoardDisplayDataOutput(msg.content.data),
                    metadata: msg.content.metadata,
                    transient: msg.content.transient
                })
            );