Struct Connection 

pub struct Connection { /* private fields */ }

Implementations

impl Connection

pub async fn connect( reg: &Registration, config: &Configuration, server_name: &str, server_port: u16, ) -> Result<Self, Status>

Connects to the server Note: Registration must be kept outside of connection and must wait for all connections to finish before closing, else registration close will wait on system lock, and block rust runtime.

pub fn get_shutdown_waiter(&mut self) -> ConnectionShutdownWaiter

Can only be called once after construction.

Trait Implementations

impl<B: Buf> Connection<B> for Connection

Server accept streams

type RecvStream = H3RecvStream

The type produced by poll_accept_recv()

type OpenStreams = StreamOpener

A producer of outgoing Unidirectional and Bidirectional streams.

fn poll_accept_recv( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Self::RecvStream, ConnectionErrorIncoming>>

Accept an incoming unidirectional stream

fn poll_accept_bidi( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Self::BidiStream, ConnectionErrorIncoming>>

Accept an incoming bidirectional stream

fn opener(&self) -> Self::OpenStreams

Get an object to open outgoing streams.

impl Debug for Connection

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<B: Buf> OpenStreams<B> for Connection

bypass for StreamOpener

type BidiStream = H3Stream

The type produced by poll_open_bidi()

type SendStream = H3SendStream

The type produced by poll_open_send()

fn poll_open_bidi( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Self::BidiStream, StreamErrorIncoming>>

Poll the connection to create a new bidirectional stream.

fn poll_open_send( &mut self, cx: &mut Context<'_>, ) -> Poll<Result<Self::SendStream, StreamErrorIncoming>>

Poll the connection to create a new unidirectional stream.

fn close(&mut self, code: Code, reason: &[u8])

Close the connection immediately