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.

pub async fn serve_connection_grpc( &self, stream: PolledSocket<impl AsSockRef + Read + Write>, ) -> Result<()>

Services a single, already-accepted connection using the gRPC (HTTP/2) protocol.

This is useful when the caller owns the accept loop, for example to dispatch a connection to gRPC or another protocol based on a sniffed prefix byte.

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.

pub async fn serve_connection( &self, stream: PolledSocket<impl AsSockRef + Read + Write>, ) -> Result<()>

Services a single, already-accepted connection using the ttrpc protocol.

This is useful when the caller owns the accept loop, for example to dispatch a connection to ttrpc or another protocol based on a sniffed prefix byte.

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.