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

JupyterZmqSocket

interface JupyterZmqSocket : JupyterSendReceiveSocket, Closeable

Inheritors

JupyterZmqSocketImpl

Properties

abstract val zmqSocket: ZmqSocketWithCancellation

Functions

abstract fun bind(): Boolean

fun JupyterSendReceiveSocket.callbackBased(logger: Logger): JupyterCallbackBasedSocketImpl

The callbacks won't be handled unless JupyterCallbackBasedSocketImpl.receiveMessageAndRunCallbacks is called!

abstract override fun close()

abstract fun connect(): Boolean

fun JupyterReceiveSocket.receiveMessage(): Message?

receiveRawMessage

abstract fun receiveRawMessage(): RawMessage?

Blocks until a message arrives. If an error occurs during the receipt of the message, null is returned and the error is logged. Returns null when an error occurs during the receipt of the message (the error will be logged).

fun JupyterSendSocket.sendMessage(msg: Message)

abstract fun sendRawMessage(msg: RawMessage)