ksrpc-sockets/com.monkopedia.ksrpc.sockets

Package-level declarations

Implementation of ksrpc channels that communicate using POSIX sockets or STD IN/OUT.

Functions

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

Create a Connection for the given input/output channel.

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

Helper that calls into Pair.asConnection.

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

fun posixFileReadChannel(fd: Int): ByteReadChannel

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

fun posixFileWriteChannel(fd: Int): ByteWriteChannel

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

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

expect fun termios.setICanon()

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

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)