Struct Connection

pub struct Connection(/* private fields */);

Implementations

impl Connection

pub fn new(registration: &Registration) -> Result<Self, ConnectionError>

Create a new connection.

The connection is not started until start is called.

pub fn start<'a>( &'a self, configuration: &'a Configuration, host: &'a str, port: u16, ) -> ConnectionStart<'a>

Start the connection.

pub fn open_outbound_stream( &self, stream_type: StreamType, fail_on_blocked: bool, ) -> OpenOutboundStream<'_>

Open a new outbound stream.

pub fn accept_inbound_stream(&self) -> AcceptInboundStream<'_>

Accept an inbound bidilectional stream.

pub fn poll_accept_inbound_stream( &self, cx: &mut Context<'_>, ) -> Poll<Result<Stream, StreamStartError>>

Poll to accept an inbound bidilectional stream.

pub fn accept_inbound_uni_stream(&self) -> AcceptInboundUniStream<'_>

Accept an inbound unidirectional stream.

pub fn poll_accept_inbound_uni_stream( &self, cx: &mut Context<'_>, ) -> Poll<Result<ReadStream, StreamStartError>>

Poll to accept an inbound unidirectional stream.

pub fn poll_receive_datagram( &self, cx: &mut Context<'_>, ) -> Poll<Result<Bytes, DgramReceiveError>>

Poll to receive a datagram.

pub fn poll_send_datagram( &self, cx: &mut Context<'_>, buf: &Bytes, ) -> Poll<Result<(), DgramSendError>>

Poll to send a datagram.

pub fn send_datagram(&self, buf: &Bytes) -> Result<(), DgramSendError>

Send a datagram.

pub fn poll_shutdown( &self, cx: &mut Context<'_>, error_code: u64, ) -> Poll<Result<(), ShutdownError>>

Poll to shutdown the connection.

pub fn shutdown(&self, error_code: u64) -> Result<(), ShutdownError>

Shutdown the connection.

pub fn get_local_addr(&self) -> Result<SocketAddr, ConnectionError>

Get the local address of the connection.

pub fn get_remote_addr(&self) -> Result<SocketAddr, ConnectionError>

Get the remote address of the connection.

Trait Implementations

impl Clone for Connection

fn clone(&self) -> Connection

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.