Struct Group 

pub struct Group { /* private fields */ }

A group of quiche:Connections.

Implementations

impl Group

pub fn new() -> Self

Create a group with default parameters.

pub fn recv_with_connection_id( &self, scid: &ConnectionId<'_>, buf: &mut [u8], info: RecvInfo, unparker: Option<&Unparker>, ) -> Result<(Token, usize)>

Process a packet recv. Processes QUIC packets received from the peer.

Trait Implementations

impl Default for Group

fn default() -> Self

Returns the “default value” for a type.

impl QuicClient for Group

Available on crate feature server only.

fn connect( &self, server_name: Option<&str>, local: SocketAddr, peer: SocketAddr, config: &mut Config, ) -> Result<Token>

Creates a new client-side connection.

impl QuicPoll for Group

fn register(&self, wrapped: Connection) -> Result<Token>

Wrap and register a new quiche::Connection.

fn deregister(&self, token: Token) -> Result<Connection>

Unwrap a bound quiche::Connection

fn len(&self) -> usize

Returns number of connections in the group.

fn close( &self, token: Token, app: bool, err: u64, reason: Cow<'static, [u8]>, ) -> Result<()>

Close one connection.

fn stream_open( &self, token: Token, kind: StreamKind, non_blocking: bool, ) -> Result<Option<u64>>

Open a outbound stream.

fn stream_shutdown(&self, token: Token, stream_id: u64, err: u64) -> Result<()>

Shutdown a stream.

fn stream_send( &self, token: Token, stream_id: u64, buf: &[u8], fin: bool, ) -> Result<usize>

Writes data to a stream.

fn stream_recv( &self, token: Token, stream_id: u64, buf: &mut [u8], ) -> Result<(usize, bool)>

Reads contiguous data from a stream into the provided slice.

fn poll(&self, events: &mut Vec<Event>) -> Result<Option<Instant>>

Waits for readiness events without blocking current thread and returns possible retry time duration.

type Error = Error

impl QuicServerTransport for Group

Available on crate feature server only.

fn recv_with_acceptor( &self, acceptor: &mut Acceptor, buf: &mut [u8], recv_size: usize, recv_info: RecvInfo, unparker: Option<&Unparker>, ) -> Result<(usize, SendInfo)>

Server-side recv function, supports for QUIC handshake process.

impl QuicTransport for Group

fn recv(&self, buf: &mut [u8], info: RecvInfo) -> Result<usize>

Processes QUIC packets received from the peer.

fn send(&self, token: Token, buf: &mut [u8]) -> Result<(usize, SendInfo)>

Writes a single QUIC packet to be sent to the peer.

type Error = Error