asConnection

import com.monkopedia.ksrpc.channels.connect
import com.monkopedia.ksrpc.ksrpcEnvironment
import com.monkopedia.ksrpc.serialized
import com.monkopedia.ksrpc.sockets.asConnection
import com.monkopedia.ksrpc.sockets.withStdInOut
import com.monkopedia.ksrpc.toStub
import io.ktor.utils.io.ByteChannel

fun main() { 
   //sampleStart 
   val env = ksrpcEnvironment { }

// Create a pair of byte channels (simulating a socket pair).
val readChannel = ByteChannel(autoFlush = true)
val writeChannel = ByteChannel(autoFlush = true)

// Any Pair<ByteReadChannel, ByteWriteChannel> can become a Connection.
val connection = (readChannel to writeChannel).asConnection(env)

// Register a service on the connection.
val service = object : GreetingService {
    override suspend fun greet(name: String): String = "Hello, $name!"
}
connection.registerDefault(service.serialized(env)) 
   //sampleEnd
}