libnexakotlin/org.nexa.libnexakotlin.socketKtor/TcpSocket

TcpSocket

class TcpSocket(val sendCtxt: CoroutineContext, val receiveCtxt: CoroutineContext)

Constructors

constructor(sendCtxt: CoroutineContext, receiveCtxt: CoroutineContext)

Properties

availableForRead

open val availableForRead: Int

Returns number of bytes that can be read without blocking

var inp: <Error class: unknown class>?

open val localAddress: <Error class: unknown class>

var out: <Error class: unknown class>?

val receiveCtxt: CoroutineContext

open val remoteAddress: <Error class: unknown class>

selectorManager

var selectorManager: <Error class: unknown class>

val sendCtxt: CoroutineContext

var sock: <Error class: unknown class>?

var sockBuilder: <Error class: unknown class>

Functions

fun awaitContent(scope: <Error class: unknown class>, cb: () -> Unit)

open fun close()

open fun connect(name: String, port: Int, connectTimeout: Int, sockOptions: <Error class: unknown class>.() -> Unit?)

open fun finalize()

open fun flush()

force any writes to actually be sent

open fun isAlive(): Boolean

open fun readAvailable(dst: ByteArray, offset: Int, length: Int): Int

open fun writeFully(src: ByteArray, offset: Int, length: Int)

Writes all src bytes and suspends until all bytes written. Causes flush if buffer filled up or when autoFlush Crashes if channel get closed while writing