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

JupyterZmqSocketImpl

class JupyterZmqSocketImpl(loggerFactory: KernelLoggerFactory, val name: String, socket: ZMQ.Socket, address: String, hmac: HMAC) : Closeable, JupyterZmqSocket

Constructors

JupyterZmqSocketImpl

constructor(loggerFactory: KernelLoggerFactory, name: String, socket: ZMQ.Socket, address: String, hmac: HMAC)

Properties

val name: String

open override val zmqSocket: ZmqSocketWithCancellationImpl

Functions

open override fun bind(): Boolean

fun JupyterSendReceiveSocket.callbackBased(logger: Logger): JupyterCallbackBasedSocketImpl

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

open override fun close()

open override fun connect(): Boolean

fun JupyterReceiveSocket.receiveMessage(): Message?

receiveRawMessage

open override 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)

open override fun sendRawMessage(msg: RawMessage)