Struct quic_rpc::server::Accepting

pub struct Accepting<S: Service, C: ServiceEndpoint<S>> { /* private fields */ }

The result of accepting a new connection.

Implementations

impl<S: Service, C: ServiceEndpoint<S>> Accepting<S, C>

pub async fn read_first( self, ) -> Result<(S::Req, RpcChannel<S, C>), RpcServerError<C>>

Read the first message from the client.

The return value is a tuple of (request, channel). Here request is the first request which is already read from the stream. The channel is a RpcChannel that has sink and stream fields that can be used to send more requests and/or receive more responses.

Often sink and stream will wrap an an underlying byte stream. In this case you can call into_inner() on them to get it back to perform byte level reads and writes.