Struct toy_rpc::server::ServerBuilder

pub struct ServerBuilder { /* fields omitted */ }

Implementations

impl ServerBuilder

pub fn new() -> Self

Creates a new ServerBuilder

pub fn register<S>(self, service: Arc<S>) -> Self where
    S: RegisterService + Send + Sync + 'static, 

Registers a new service to the Server

Example

use async_std::net::TcpListener;
use async_std::sync::Arc;
use toy_rpc_macros::{export_impl, service};
use toy_rpc::server::Server;

struct EchoService { }

#[export_impl]
impl EchoService {
    #[export_method]
    async fn echo(&self, req: String) -> Result<String, String> {
        Ok(req)
    }
}

#[async_std::main]
async fn main() {
    let addr = "127.0.0.1:8080";
     
    let echo_service = Arc::new(EchoService { });
    let server = Server::builder()
        .register(echo_service)
        .build();
     
    let listener = TcpListener::bind(addr).await.unwrap();

    let handle = task::spawn(async move {
        server.accept(listener).await.unwrap();
    });

    handle.await;
}

pub fn build(self) -> Server

Creates an RPC Server

Trait Implementations

impl Default for ServerBuilder

fn default() -> Self

Returns the “default value” for a type.