import { Observable } from 'rxjs'; import { Scope } from './state'; import { type WorkersPoolTypes } from '@youwol/webpm-client'; /** * Execute a given JavaScript or Python statement within a workers' pool. * This is only for non-reactive cells. * * @param _args * @param _args.src The source to execute. * @param _args.mode The script's language. * @param _args.scope The entering scope. * @param _args.workersPool The workers' pool. * @param _args.capturedIn Variable's names captured from the main thread and forwarded to the worker. * @param _args.capturedOut Variable's names captured from the worker and forwarded to the main thread. * @returns Promise over the scope at exit. */ export declare function executeWorkersPool({ src, mode, workersPool, scope, capturedIn, capturedOut, }: { src: string; mode: 'javascript' | 'python'; workersPool: WorkersPoolTypes.WorkersPool; scope: Scope; capturedIn: { [_k: string]: unknown; }; capturedOut: string[]; }): Promise; /** * Execute a given JavaScript or Python statement within a workers' pool. * This is only for reactive cells. * * @param _args * @param _args.src The source to execute. * @param _args.mode The script's language. * @param _args.scope The entering scope. * @param _args.workersPool The workers' pool. * @param _args.capturedIn Variable's names captured from the main thread and forwarded to the worker. * @param _args.capturedOut Variable's names captured from the worker and forwarded to the main thread. * @param _args.invalidated$ Observable that emits when the associated cell is invalidated. * @returns Promise over the scope at exit. */ export declare function executeWorkersPool$({ src, mode, workersPool, scope, capturedIn, capturedOut, invalidated$, }: { src: string; mode: 'javascript' | 'python'; workersPool: WorkersPoolTypes.WorkersPool; scope: Scope; capturedIn: { [_k: string]: unknown; }; capturedOut: string[]; invalidated$: Observable; }): Promise;