connector-ktor-network/com.river.connector.ktor.network

Package-level declarations

Types

Link copied to clipboard
object Tcp : ServerTcpExtensions, ClientTcpExtensions

Properties

Link copied to clipboard
val Connection.isClosedForRead: Boolean
Link copied to clipboard
val Connection.isClosedForWrite: Boolean
Link copied to clipboard
val Connection.isConnectionActive: Boolean
Link copied to clipboard
val ByteArray.packet: ByteReadPacket

Functions

Link copied to clipboard
inline suspend fun Connection.awaitBytes(size: Int = 8): ByteArray
Link copied to clipboard
suspend fun Connection.awaitClosed()
Link copied to clipboard
inline suspend fun Connection.awaitLine(): String?
inline suspend fun Connection.awaitLine(ifEmpty: () -> String): String
Link copied to clipboard
fun Connection.close()
Link copied to clipboard
inline fun <T> Connection.flowOf(crossinline next: suspend Connection.() -> T): Flow<T>
Link copied to clipboard
inline fun Connection.flowOfByteArray(size: Int = 8): Flow<ByteArray>
Link copied to clipboard
inline fun Connection.flowOfBytes(): Flow<Byte>
Link copied to clipboard
inline fun Connection.flowOfLines(): Flow<String>
Link copied to clipboard
inline fun Connection.flush(f: Connection.() -> Unit)
Link copied to clipboard
inline fun <T> Connection.use(block: (Connection) -> T): T
Link copied to clipboard
suspend fun Connection.whileActive(operation: suspend Connection.() -> Unit)
Link copied to clipboard
inline suspend fun Connection.write(data: ByteArray, flush: Boolean = false)
inline suspend fun Connection.write(data: CharSequence, flush: Boolean = false)
Link copied to clipboard
inline suspend fun Connection.writeLine(data: CharSequence = "", flush: Boolean = false)