Struct Connection

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

Accepted connection, which can be a TCP socket, AF_UNIX stream socket or a stdin/stdout pair.

Although inner enum is private, you can use methods or From impls to convert this to/from usual Tokio types.

Implementations

impl Connection

pub fn try_into_tcp(self) -> Result<TcpStream, Self>

pub fn try_into_unix(self) -> Result<UnixStream, Self>

pub fn try_into_stdio(self) -> Result<(Stdin, Stdout, Option<Sender<()>>), Self>

Get parts of the connection in case of inted mode is used.

Third tuple part (Sender) should be used to signal [Listener] to exit from listening loop, allowing proper timing of listening termination - without trying to wait for second client in inetd mode, but also without exiting prematurely, while the client is still being served, as exiting the listening loop may cause the whole process to finish.

pub fn try_borrow_tcp(&self) -> Option<&TcpStream>

pub fn try_borrow_unix(&self) -> Option<&UnixStream>

pub fn try_borrow_stdio(&self) -> Option<(&Stdin, &Stdout)>

Trait Implementations

impl AsyncRead for Connection

fn poll_read( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &mut ReadBuf<'_>, ) -> Poll<Result<()>>

Attempts to read from the AsyncRead into buf.

impl AsyncWrite for Connection

fn poll_write( self: Pin<&mut Self>, cx: &mut Context<'_>, buf: &[u8], ) -> Poll<Result<usize, Error>>

Attempt to write bytes from buf into the object.

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Attempts to flush the object, ensuring that any buffered data reach their destination.

fn poll_shutdown( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Initiates or attempts to shut down this writer, returning success when the I/O connection has completely shut down.

fn poll_write_vectored( self: Pin<&mut Self>, cx: &mut Context<'_>, bufs: &[IoSlice<'_>], ) -> Poll<Result<usize, Error>>

Like poll_write, except that it writes from a slice of buffers.

fn is_write_vectored(&self) -> bool

Determines if this writer has an efficient poll_write_vectored implementation.

impl Connected for Connection

type ConnectInfo = ListenerConnectInfo

The connection info type the IO resources generates.

fn connect_info(&self) -> Self::ConnectInfo

Create type holding information about the connection.

impl Debug for Connection

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

Formats the value using the given formatter.

impl From<(Stdin, Stdout, Option<Sender<()>>)> for Connection

fn from(s: (Stdin, Stdout, Option<Sender<()>>)) -> Self

Converts to this type from the input type.

impl From<TcpStream> for Connection

fn from(s: TcpStream) -> Self

Converts to this type from the input type.

impl From<UnixStream> for Connection

fn from(s: UnixStream) -> Self

Converts to this type from the input type.

impl<'pin> Unpin for Connection

where PinnedFieldsOf<__Connection<'pin>>: Unpin,