shared-compiler/org.jetbrains.kotlinx.jupyter.messaging/IdeCompatibleMessageRequestProcessor

IdeCompatibleMessageRequestProcessor

open class IdeCompatibleMessageRequestProcessor(rawIncomingMessage: RawMessage, messageFactoryProvider: MessageFactoryProvider, val socketManager: JupyterBaseSockets, commManager: CommManagerInternal, executor: JupyterExecutor, executionCounter: ExecutionCounter, loggerFactory: KernelLoggerFactory, repl: ReplForJupyter) : AbstractMessageRequestProcessor, JupyterCommunicationFacility

Constructors

IdeCompatibleMessageRequestProcessor

constructor(rawIncomingMessage: RawMessage, messageFactoryProvider: MessageFactoryProvider, socketManager: JupyterBaseSockets, commManager: CommManagerInternal, executor: JupyterExecutor, executionCounter: ExecutionCounter, loggerFactory: KernelLoggerFactory, repl: ReplForJupyter)

Properties

override val messageFactory: MessageFactory

override val socketManager: JupyterBaseSockets

Functions

doWrappedInBusyIdle

fun JupyterCommunicationFacility.doWrappedInBusyIdle(action: () -> Unit)

fun JupyterCommunicationFacility.getInput(prompt: String = DefaultPromptOptions.PROMPT, password: Boolean = DefaultPromptOptions.IS_PASSWORD): String

processControlMessage

open override fun processControlMessage()

processShellMessage

open override fun processShellMessage()

processStdinMessage

open override fun processStdinMessage()

fun JupyterCommunicationFacility.sendError(response: JupyterResponse, executionCount: ExecutionCount, startedTime: String)

Send a message to clients of the type "error" as the response to an "execute_request" message that resulted in the REPL throwing an exception.

sendExecuteReply

fun JupyterCommunicationFacility.sendExecuteReply(response: JupyterResponse, executionCount: ExecutionCount, startedTime: String)

sendExecuteResult

fun JupyterCommunicationFacility.sendExecuteResult(result: DisplayResult?, executionCount: ExecutionCount)

fun JupyterCommunicationFacility.sendOut(stream: JupyterOutType, text: String)

fun JupyterCommunicationFacility.sendResponse(response: JupyterResponse, executionCount: ExecutionCount, startedTime: String)

sendSimpleMessageToIoPub

fun JupyterCommunicationFacility.sendSimpleMessageToIoPub(msgType: MessageType, content: AbstractMessageContent)

fun JupyterCommunicationFacility.sendStatus(status: KernelStatus)

fun JupyterCommunicationFacility.sendWrapped(message: Message)