shared-compiler/org.jetbrains.kotlinx.jupyter.protocol/JupyterCallbackBasedSocketImpl

JupyterCallbackBasedSocketImpl

interface JupyterCallbackBasedSocketImpl : JupyterCallbackBasedSocket

Functions

abstract fun onRawMessage(callback: RawMessageCallback)

abstract fun receiveMessageAndRunCallbacks()

Blocks until a message arrives. Runs all registered callbacks on it when it happens. If an error occurs during the receipt of the message, the message is skipped and the error is logged.

sendMessage

fun JupyterSendSocket.sendMessage(msg: Message)

sendRawMessage

abstract fun sendRawMessage(msg: RawMessage)

sendReceive

fun JupyterCallbackBasedSocket.sendReceive(messageBufferCapacity: Int = 256): JupyterSendReceiveSocket

Receiving messages when the buffer is full will block the incoming message processor thread (the thread which runs JupyterCallbackBasedSocketImpl.receiveMessageAndRunCallbacks).