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

JupyterCommunicationFacilityImpl

class JupyterCommunicationFacilityImpl(val socketManager: JupyterBaseSockets, messageFactoryProvider: Provider<MessageFactory>) : JupyterCommunicationFacility

Constructors

JupyterCommunicationFacilityImpl

constructor(socketManager: JupyterBaseSockets, messageFactoryProvider: Provider<MessageFactory>)

Properties

open override val messageFactory: MessageFactory

open override val socketManager: JupyterBaseSockets

Functions

doWrappedInBusyIdle

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

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

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)