Struct Connection

pub struct Connection<C, B>
where
    C: Connection<B>,
    B: Buf,
{ /* private fields */ }

Implementations

impl<C, B, E, E2> Connection<C, B>

where C: Connection<B> + SendDatagramExt<B, Error = E> + RecvDatagramExt<Buf = B, Error = E2> + 'static, B: Buf + 'static + Send + Sync, C::AcceptError: Send + Sync, C::BidiStream: Send + Sync, C::RecvStream: Send + Sync, C::OpenStreams: Send + Sync, E: Into<Error>, E2: Into<Error>,

pub fn new(inner: Connection<C, B>) -> Self

Create a new WebTransportServer

pub fn split(self) -> (Incoming<C, B>, ConnectionDriver<C, B>)

Take the request acceptor

pub fn driver(&mut self) -> &mut ConnectionDriver<C, B>

Get a mutable reference to the driver

pub async fn accept( &mut self, ) -> Result<Option<(Request<()>, RequestStream<C::BidiStream, B>)>, Error>

Accepts an incoming request Internally this method will drive the server until an incoming request is available And returns the request and a request stream.

impl<C, B> Connection<C, B>

where C: Connection<B>, B: Buf,

pub fn close(&mut self, code: Code, reason: &str) -> Error

Closes the connection with a code and a reason.