Struct Server

pub struct Server { /* private fields */ }

A ttrpc server.

Implementations

impl Server

pub async fn run_grpc( &mut self, driver: &(impl Driver + ?Sized), listener: impl Listener, cancel: OneshotReceiver<()>, ) -> Result<()>

Runs the server using the gRPC transport, listening on listener and servicing connections until cancel.

impl Server

pub fn new() -> Self

Creates a new ttrpc server.

pub fn add_service<T: ServiceRpc>(&mut self) -> RpcReceiver<T>

Adds or updates a channel for receiving service requests.

pub async fn run( &mut self, driver: &(impl Driver + ?Sized), listener: impl Listener, cancel: OneshotReceiver<()>, ) -> Result<()>

Runs the server using the ttrpc transport, listening on listener and servicing connections until cancel.

pub async fn run_single( &mut self, driver: &(impl Driver + ?Sized), conn: impl AsSockRef + Read + Write, ) -> Result<()>

Runs the server, servicing a single connection conn.

Trait Implementations

impl Debug for Server

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for Server

fn default() -> Server

Returns the “default value” for a type.