asJsonRpcConnection

import com.monkopedia.ksrpc.channels.connect
import com.monkopedia.ksrpc.jsonrpc.asJsonRpcConnection
import com.monkopedia.ksrpc.jsonrpc.stdInJsonRpcConnection
import com.monkopedia.ksrpc.ksrpcEnvironment
import com.monkopedia.ksrpc.serialized
import com.monkopedia.ksrpc.toStub
import io.ktor.utils.io.ByteChannel

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

// Any pair of byte read/write channels can be a JSON-RPC connection.
val readChannel = ByteChannel(autoFlush = true)
val writeChannel = ByteChannel(autoFlush = true)

val connection = (readChannel to writeChannel).asJsonRpcConnection(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
}

import com.monkopedia.ksrpc.channels.connect
import com.monkopedia.ksrpc.jsonrpc.asJsonRpcConnection
import com.monkopedia.ksrpc.jsonrpc.stdInJsonRpcConnection
import com.monkopedia.ksrpc.ksrpcEnvironment
import com.monkopedia.ksrpc.serialized
import com.monkopedia.ksrpc.toStub
import io.ktor.utils.io.ByteChannel

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

// stdInJsonRpcConnection creates a SingleChannelConnection over stdin/stdout
// using JSON-RPC 2.0 framing with Content-Length headers.
val connection = stdInJsonRpcConnection(env)

// Use connect to set up both host and client sides.
connection.connect<GreetingService, GreetingService, String> { remoteService ->
    // remoteService is a stub for the remote side's hosted service.
    // Return the local service to host on this side.
    object : GreetingService {
        override suspend fun greet(name: String): String = "Hello from server, $name!"
    }
} 
   //sampleEnd
}