SocketWrapper

class SocketWrapper(loggerFactory: KernelLoggerFactory, val name: String, socket: ZMQ.Socket, address: String, hmac: HMAC) : SocketWithCancellationBase, JupyterSocket

Constructors

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

Properties

Link copied to clipboard

Functions

Link copied to clipboard
open override fun bind(): Boolean
Link copied to clipboard
open override fun close()
Link copied to clipboard
open override fun connect(): Boolean
Link copied to clipboard
open override fun makeRelaxed()
Link copied to clipboard
open override fun onData(body: JupyterSocket.(ByteArray) -> Unit)
Link copied to clipboard
Link copied to clipboard
Link copied to clipboard
open override fun receiveRawMessage(): RawMessage?
Link copied to clipboard
open override fun recv(): ByteArray
Link copied to clipboard
open override fun recvString(): String
Link copied to clipboard
open override fun removeCallback(callback: SocketRawMessageCallback)
Link copied to clipboard
open override fun runCallbacksOnMessage(): Unit?
Link copied to clipboard
open override fun send(data: ByteArray): Boolean
open override fun send(data: String): Boolean
Link copied to clipboard
Link copied to clipboard
open override fun sendMore(data: ByteArray): Boolean
open override fun sendMore(data: String): Boolean
Link copied to clipboard
open override fun sendRawMessage(msg: RawMessage)
Link copied to clipboard
open override fun subscribe(topic: ByteArray): Boolean