Function quic_rpc::server::run_server_loop
source · pub async fn run_server_loop<S, C, T, F, Fut>(
_service_type: S,
_channel_type: C,
conn: C::ServerChannel<S::Req, S::Res>,
target: T,
handler: F
) -> Result<(), RpcServerError<C>>where
S: Service,
C: ChannelTypes,
T: Clone + Send + 'static,
F: FnMut(RpcServer<S, C>, S::Req, (C::SendSink<S::Res>, C::RecvStream<S::Req>), T) -> Fut + Send + 'static,
Fut: Future<Output = Result<RpcServer<S, C>, RpcServerError<C>>> + Send + 'static,
Expand description
Run a server loop, invoking a handler callback for each request.
Requests will be handled sequentially.