import { DisposableDelegate } from '@lumino/disposable'; import * as Kernel from './kernel'; import * as KernelMessage from './messages'; /** * Implementation of a kernel future. * * If a reply is expected, the Future is considered done when both a `reply` * message and an `idle` iopub status message have been received. Otherwise, it * is considered done when the `idle` status is received. * */ export declare abstract class KernelFutureHandler extends DisposableDelegate implements Kernel.IFuture { /** * Construct a new KernelFutureHandler. */ constructor(cb: () => void, msg: REQUEST, expectReply: boolean, disposeOnDone: boolean, kernel: Kernel.IKernelConnection); /** * Get the original outgoing message. */ get msg(): REQUEST; /** * A promise that resolves when the future is done. */ get done(): Promise; /** * Get the reply handler. */ get onReply(): (msg: REPLY) => void | PromiseLike; /** * Set the reply handler. */ set onReply(cb: (msg: REPLY) => void | PromiseLike); /** * Get the iopub handler. */ get onIOPub(): (msg: KernelMessage.IIOPubMessage) => void | PromiseLike; /** * Set the iopub handler. */ set onIOPub(cb: (msg: KernelMessage.IIOPubMessage) => void | PromiseLike); /** * Get the stdin handler. */ get onStdin(): (msg: KernelMessage.IStdinMessage) => void | PromiseLike; /** * Set the stdin handler. */ set onStdin(cb: (msg: KernelMessage.IStdinMessage) => void | PromiseLike); /** * Register hook for IOPub messages. * * @param hook - The callback invoked for an IOPub message. * * #### Notes * The IOPub hook system allows you to preempt the handlers for IOPub * messages handled by the future. * * The most recently registered hook is run first. A hook can return a * boolean or a promise to a boolean, in which case all kernel message * processing pauses until the promise is fulfilled. If a hook return value * resolves to false, any later hooks will not run and the function will * return a promise resolving to false. If a hook throws an error, the error * is logged to the console and the next hook is run. If a hook is * registered during the hook processing, it will not run until the next * message. If a hook is removed during the hook processing, it will be * deactivated immediately. */ registerMessageHook(hook: (msg: KernelMessage.IIOPubMessage) => boolean | PromiseLike): void; /** * Remove a hook for IOPub messages. * * @param hook - The hook to remove. * * #### Notes * If a hook is removed during the hook processing, it will be deactivated immediately. */ removeMessageHook(hook: (msg: KernelMessage.IIOPubMessage) => boolean | PromiseLike): void; /** * Send an `input_reply` message. */ sendInputReply(content: KernelMessage.IInputReplyMsg['content'], parent_header: KernelMessage.IInputReplyMsg['parent_header']): void; /** * Dispose and unregister the future. */ dispose(): void; /** * Handle an incoming kernel message. */ handleMsg(msg: KernelMessage.IMessage): Promise; private _handleReply; private _handleStdin; private _handleIOPub; private _handleDone; /** * Test whether the given future flag is set. */ private _testFlag; /** * Set the given future flag. */ private _setFlag; private _msg; private _status; private _stdin; private _iopub; private _reply; private _done; private _replyMsg; private _hooks; private _disposeOnDone; private _kernel; } export declare class KernelControlFutureHandler extends KernelFutureHandler implements Kernel.IControlFuture { } export declare class KernelShellFutureHandler extends KernelFutureHandler implements Kernel.IShellFuture { }