Crate quic_rpc

Expand description

A streaming rpc system based on quic

Motivation

Example

use quic_rpc::{message::RpcMsg, Service, RpcClient, transport::MemChannelTypes};
use serde::{Serialize, Deserialize};
use derive_more::{From, TryInto};

// Define your messages
#[derive(Debug, Serialize, Deserialize)]
struct Ping;

#[derive(Debug, Serialize, Deserialize)]
struct Pong;

// Define your RPC service and its request/response types

#[derive(Debug, Serialize, Deserialize, From, TryInto)]
enum PingRequest {
    Ping(Ping),
}

#[derive(Debug, Serialize, Deserialize, From, TryInto)]
enum PingResponse {
    Pong(Pong),
}

#[derive(Debug, Clone)]
struct PingService;

impl Service for PingService {
  type Req = PingRequest;
  type Res = PingResponse;
}

// Define interaction patterns for each request type
impl RpcMsg<PingService> for Ping {
  type Response = Pong;
}

// create a transport channel
let (server, client) = quic_rpc::transport::mem::connection::<PingRequest, PingResponse>(1);

// create the rpc client given the channel and the service type
let mut client = RpcClient::<PingService, MemChannelTypes>::new(client);

// call the service
let res = client.rpc(Ping).await?;