ksrpc-sockets/com.monkopedia.ksrpc.sockets

Package-level declarations

Public API: ReadWriteChannel factory functions, stdin/stdout stream helpers, and platform adapters for JVM InputStream/OutputStream, native POSIX file descriptors, and JS process streams.

Functions

asConnection

suspend fun Pair<ByteReadChannel, ByteWriteChannel>.asConnection(env: KsrpcEnvironment<String>): Connection<String>

Create a Connection for the given input/output channel.

fun Pair<ByteReadChannel, ByteWriteChannel>.asConnection(scope: CoroutineScope, env: KsrpcEnvironment<String>): Connection<String>

Create a Connection for the given input/output channel using a caller-provided scope.

suspend fun ProcessBuilder.asConnection(env: KsrpcEnvironment<String>): Connection<String>

Create a Connection that starts the process and uses the Process.getInputStream and Process.getOutputStream as the streams for communication

suspend fun Pair<InputStream, OutputStream>.asConnection(env: KsrpcEnvironment<String>): Connection<String>

Helper that calls into Pair.asConnection.

initTermios

fun initTermios(fd: Int = STDIN_FILENO, old: CPointer<termios>)

posixFileReadChannel

fun posixFileReadChannel(fd: Int): ByteReadChannel

Creates a ByteReadChannel that will read bytes from the specified file descriptor fd.

posixFileWriteChannel

fun posixFileWriteChannel(fd: Int): ByteWriteChannel

Creates a ByteWriteChannel that will write bytes to the specified file descriptor fd.

resetTermios

fun resetTermios(fd: Int = STDIN_FILENO, old: CPointer<termios>)

setICanon

actual fun ERROR CLASS: Symbol not found for termios.setICanon()

actual fun termios.setICanon()

actual fun ERROR CLASS: Symbol not found for termios.setICanon()

expect fun termios.setICanon()

withoutIcanon

inline fun withoutIcanon(fd: Int = STDIN_FILENO, callback: () -> Unit)

withStdInOut

expect inline suspend fun withStdInOut(ksrpcEnvironment: KsrpcEnvironment<String>, withConnection: (Connection<String>) -> Unit)

Create a Connection that communicates over the std in/out streams of this process.

actual inline suspend fun withStdInOut(ksrpcEnvironment: KsrpcEnvironment<String>, withConnection: (Connection<String>) -> Unit)

Create a Connection that communicates over the std in/out streams of this process.

actual inline suspend fun withStdInOut(ksrpcEnvironment: KsrpcEnvironment<String>, withConnection: (Connection<String>) -> Unit)

Create a Connection that communicates over the std in/out streams of this process.