Struct TcpMicroserviceServer 

pub struct TcpMicroserviceServer { /* private fields */ }

Implementations

impl TcpMicroserviceServer

pub fn new( options: TcpMicroserviceOptions, handlers: Vec<Arc<dyn MicroserviceHandler>>, ) -> Self

pub async fn listen(self) -> Result<(), TransportError>

pub async fn listen_with_shutdown<F>( self, shutdown: F, ) -> Result<(), TransportError>

where F: Future<Output = ()> + Send + 'static,

Trait Implementations

impl MicroserviceServer for TcpMicroserviceServer

fn listen_with_shutdown<'async_trait>( self: Box<Self>, shutdown: ShutdownFuture, ) -> Pin<Box<dyn Future<Output = Result<(), TransportError>> + Send + 'async_trait>>

where Self: 'async_trait,