JsonRpc

A JSON-RPC 2.0 session between two peers.

Create an instance with JsonRpc.of, providing a JsonRpcTransportSession that handles the raw byte/string transport (WebSocket, TCP, stdio, SSE, etc.):

val jsonRpc = JsonRpc.of(myTransportSession)

Sending messages

• request — sends a call and suspends until the remote peer replies or the timeout elapses.

• notify — sends a fire-and-forget message; the remote peer MUST NOT reply.

Both functions are safe to call concurrently from multiple coroutines.

Receiving messages

Consume callsInbox to handle incoming requests and notifications from the remote peer. See callsInbox for the recommended consumption patterns.

Error observability

• localErrors — protocol errors detected locally (e.g. malformed incoming JSON).

• remoteErrors — error responses received from the remote peer that could not be correlated to a pending request (e.g. the remote could not parse the request ID).

Lifecycle

Call close to shut down the session. It cancels internal coroutines, drains pending requests with an error, closes callsInbox, and delegates to JsonRpcTransportSession.close.