Struct tor_rtmock::io::LocalStream

source · [−]

pub struct LocalStream { /* private fields */ }

Expand description

One half of a pair of linked streams returned by stream_pair.

Implementations

source

impl LocalStream

source

pub async fn send_err(&mut self, kind: ErrorKind)

Send an error to the other linked local stream.

When the other stream reads this message, it will generate a std::io::Error with the provided ErrorKind.

Trait Implementations

source

impl AsyncRead for LocalStream

source

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

Attempt to read from the AsyncRead into buf. Read more

source

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

Attempt to read from the AsyncRead into bufs using vectored IO operations. Read more

source

impl AsyncWrite for LocalStream

source

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

Attempt to write bytes from buf into the object. Read more

source

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

Attempt to flush the object, ensuring that any buffered data reach their destination. Read more

source

fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<IoResult<()>>

Attempt to close the object. Read more

source

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

Attempt to write bytes from bufs into the object using vectored IO operations. Read more

source

impl TlsConnector<LocalStream> for MockTlsConnector

type Conn = MockTlsStream

The type of connection returned by this connector

source

fn negotiate_unvalidated<'life0, 'life1, 'async_trait>(
 &'life0 self,
 stream: LocalStream,
 _sni_hostname: &'life1 str
) -> Pin<Box<dyn Future<Output = IoResult<MockTlsStream>> + Send + 'async_trait>> where
 'life0: 'async_trait,
 'life1: 'async_trait,
 Self: 'async_trait,

Start a TLS session over the provided TCP stream stream. Read more

source

impl TlsProvider<LocalStream> for MockNetProvider

type Connector = MockTlsConnector

The Connector object that this provider can return.

type TlsStream = MockTlsStream

The type of the stream returned by that connector.

source

fn tls_connector(&self) -> MockTlsConnector

Return a TLS connector for use with this runtime.

source

impl<R: Runtime> TlsProvider<LocalStream> for MockNetRuntime<R>

type Connector = <MockNetProvider as TlsProvider<LocalStream>>::Connector

The Connector object that this provider can return.

type TlsStream = <MockNetProvider as TlsProvider<LocalStream>>::TlsStream

The type of the stream returned by that connector.

source

fn tls_connector(&self) -> Self::Connector

Return a TLS connector for use with this runtime.

Auto Trait Implementations

impl !RefUnwindSafe for LocalStream

impl Send for LocalStream

impl Sync for LocalStream

impl Unpin for LocalStream

impl !UnwindSafe for LocalStream

Blanket Implementations

source

impl<T> Any for T where
T: 'static + ?Sized,

source

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more

source

impl<R> AsyncReadExt for R where
R: AsyncRead + ?Sized,

source

fn chain<R>(self, next: R) -> Chain<Self, R> where
R: AsyncRead,

Creates an adaptor which will chain this stream with another. Read more

source

fn read(&'a mut self, buf: &'a mut [u8 ]) -> Read<'a, Self> where
Self: Unpin,

Tries to read some bytes directly into the given buf in asynchronous manner, returning a future type. Read more

source

fn read_vectored(
 &'a mut self,
 bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectored<'a, Self> where
 Self: Unpin,

Creates a future which will read from the AsyncRead into bufs using vectored IO operations. Read more

source

fn read_exact(&'a mut self, buf: &'a mut [u8 ]) -> ReadExact<'a, Self> where
Self: Unpin,

Creates a future which will read exactly enough bytes to fill buf, returning an error if end of file (EOF) is hit sooner. Read more

source

fn read_to_end(
 &'a mut self,
 buf: &'a mut Vec<u8, Global>
) -> ReadToEnd<'a, Self> where
 Self: Unpin,

Creates a future which will read all the bytes from this AsyncRead. Read more

source

fn read_to_string(&'a mut self, buf: &'a mut String) -> ReadToString<'a, Self> where
Self: Unpin,

Creates a future which will read all the bytes from this AsyncRead. Read more

source

fn split(self) -> (ReadHalf<Self>, WriteHalf<Self>) where
Self: AsyncWrite,

Helper method for splitting this read/write object into two halves. Read more

source

fn take(self, limit: u64) -> Take<Self>

Creates an AsyncRead adapter which will read at most limit bytes from the underlying reader. Read more

source

impl<R> AsyncReadExt for R where
R: AsyncRead + ?Sized,

source

fn read(&'a mut self, buf: &'a mut [u8 ]) -> ReadFuture<'a, Self> where
Self: Unpin,

Reads some bytes from the byte stream. Read more

source

fn read_vectored(
 &'a mut self,
 bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectoredFuture<'a, Self> where
 Self: Unpin,

Like read(), except it reads into a slice of buffers. Read more

source

fn read_to_end(
 &'a mut self,
 buf: &'a mut Vec<u8, Global>
) -> ReadToEndFuture<'a, Self> where
 Self: Unpin,

Reads the entire contents and appends them to a Vec. Read more

source

fn read_to_string(
 &'a mut self,
 buf: &'a mut String
) -> ReadToStringFuture<'a, Self> where
 Self: Unpin,

Reads the entire contents and appends them to a String. Read more

source

fn read_exact(&'a mut self, buf: &'a mut [u8 ]) -> ReadExactFuture<'a, Self> where
Self: Unpin,

Reads the exact number of bytes required to fill buf. Read more

source

fn take(self, limit: u64) -> Take<Self>

Creates an adapter which will read at most limit bytes from it. Read more

source

fn bytes(self) -> Bytes<Self>

Converts this AsyncRead into a Stream of bytes. Read more

source

fn chain<R>(self, next: R) -> Chain<Self, R> where
R: AsyncRead,

Creates an adapter which will chain this stream with another. Read more

source

fn boxed_reader<'a>(self) -> Pin<Box<dyn AsyncRead + Send + 'a, Global>> where
Self: 'a + Send,

Boxes the reader and changes its type to dyn AsyncRead + Send + 'a. Read more

source

impl<W> AsyncWriteExt for W where
W: AsyncWrite + ?Sized,

source

fn flush(&mut self) -> Flush<'_, Self> where
Self: Unpin,

Creates a future which will entirely flush this AsyncWrite. Read more

source

fn close(&mut self) -> Close<'_, Self> where
Self: Unpin,

Creates a future which will entirely close this AsyncWrite.

source

fn write(&'a mut self, buf: &'a [u8 ]) -> Write<'a, Self> where
Self: Unpin,

Creates a future which will write bytes from buf into the object. Read more

source

fn write_vectored(
 &'a mut self,
 bufs: &'a [IoSlice<'a>]
) -> WriteVectored<'a, Self> where
 Self: Unpin,

Creates a future which will write bytes from bufs into the object using vectored IO operations. Read more

source

fn write_all(&'a mut self, buf: &'a [u8 ]) -> WriteAll<'a, Self> where
Self: Unpin,

Write data into this object. Read more

source

fn into_sink<Item>(self) -> IntoSink<Self, Item> where
Item: AsRef<[u8 ]>,

Allow using an AsyncWrite as a Sink<Item: AsRef<[u8]>>. Read more

source

impl<W> AsyncWriteExt for W where
W: AsyncWrite + ?Sized,

source

fn write(&'a mut self, buf: &'a [u8 ]) -> WriteFuture<'a, Self> where
Self: Unpin,

Writes some bytes into the byte stream. Read more

source

fn write_vectored(
 &'a mut self,
 bufs: &'a [IoSlice<'a>]
) -> WriteVectoredFuture<'a, Self> where
 Self: Unpin,

Like write(), except that it writes a slice of buffers. Read more

source

fn write_all(&'a mut self, buf: &'a [u8 ]) -> WriteAllFuture<'a, Self> where
Self: Unpin,

Writes an entire buffer into the byte stream. Read more

source

fn flush(&mut self) -> FlushFuture<'_, Self> where
Self: Unpin,

Flushes the stream to ensure that all buffered contents reach their destination. Read more

source

fn close(&mut self) -> CloseFuture<'_, Self> where
Self: Unpin,

Closes the writer. Read more

source

fn boxed_writer<'a>(self) -> Pin<Box<dyn AsyncWrite + Send + 'a, Global>> where
Self: 'a + Send,

Boxes the writer and changes its type to dyn AsyncWrite + Send + 'a. Read more

source

impl<T> Borrow<T> for T where
T: ?Sized,

const: unstable · source

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more

source

impl<T> BorrowMut<T> for T where
T: ?Sized,

const: unstable · source

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more

source

impl<T> From<T> for T

const: unstable · source

fn from(t: T) -> T

Returns the argument unchanged.

source

impl<T> FuturesAsyncReadCompatExt for T where
T: AsyncRead,

source

fn compat(self) -> Compat<Self>

Wraps self with a compatibility layer that implements tokio_io::AsyncRead. Read more

source

impl<T> FuturesAsyncWriteCompatExt for T where
T: AsyncWrite,

source

fn compat_write(self) -> Compat<Self>

Wraps self with a compatibility layer that implements tokio::io::AsyncWrite. Read more

source

impl<T> Instrument for T

source

fn instrument(self, span: Span) -> Instrumented<Self>

Instruments this type with the provided Span, returning an Instrumented wrapper. Read more

source

fn in_current_span(self) -> Instrumented<Self>

Instruments this type with the current Span, returning an Instrumented wrapper. Read more

source

impl<T, U> Into for T where
U: From<T>,

const: unstable · source

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source

impl<T> ReadExt for T where
T: AsyncRead + ?Sized,

source

fn read(&'a mut self, buf: &'a mut [u8 ]) -> ReadFuture<'a, Self> where
Self: Unpin,

Reads some bytes from the byte stream. Read more

source

fn read_vectored(
 &'a mut self,
 bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectoredFuture<'a, Self> where
 Self: Unpin,

Like read, except that it reads into a slice of buffers. Read more

source

fn read_to_end(
 &'a mut self,
 buf: &'a mut Vec<u8, Global>
) -> ReadToEndFuture<'a, Self> where
 Self: Unpin,

Reads all bytes from the byte stream. Read more

source

fn read_to_string(
 &'a mut self,
 buf: &'a mut String
) -> ReadToStringFuture<'a, Self> where
 Self: Unpin,

Reads all bytes from the byte stream and appends them into a string. Read more

source

fn read_exact(&'a mut self, buf: &'a mut [u8 ]) -> ReadExactFuture<'a, Self> where
Self: Unpin,

Reads the exact number of bytes required to fill buf. Read more

source

fn take(self, limit: u64) -> Take<Self>

Creates an adaptor which will read at most limit bytes from it. Read more

source

fn by_ref(&mut self) -> &mut Self

Creates a “by reference” adaptor for this instance of Read. Read more

source

fn bytes(self) -> Bytes<Self>

Transforms this Read instance to a Stream over its bytes. Read more

source

fn chain<R>(self, next: R) -> Chain<Self, R> where
R: AsyncRead,

Creates an adaptor which will chain this stream with another. Read more

source

impl<T, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source

impl<T, U> TryInto for T where
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.

source

impl<T> WithSubscriber for T

source

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,

Attaches the provided Subscriber to this type, returning a WithDispatch wrapper. Read more

source

fn with_current_subscriber(self) -> WithDispatch<Self>

Attaches the current default Subscriber to this type, returning a WithDispatch wrapper. Read more

source

impl<T> WriteExt for T where
T: AsyncWrite + ?Sized,

source

fn write(&'a mut self, buf: &'a [u8 ]) -> WriteFuture<'a, Self> where
Self: Unpin,

Writes some bytes into the byte stream. Read more

source

fn flush(&mut self) -> FlushFuture<'_, Self> where
Self: Unpin,

Flushes the stream to ensure that all buffered contents reach their destination. Read more

source

fn write_vectored(
 &'a mut self,
 bufs: &'a [IoSlice<'a>]
) -> WriteVectoredFuture<'a, Self> where
 Self: Unpin,

Like write, except that it writes from a slice of buffers. Read more

source

fn write_all(&'a mut self, buf: &'a [u8 ]) -> WriteAllFuture<'a, Self> where
Self: Unpin,

Writes an entire buffer into the byte stream. Read more

source

fn write_fmt(&'a mut self, fmt: Arguments<'_>) -> WriteFmtFuture<'a, Self> where
Self: Unpin,

Writes a formatted string into this writer, returning any error encountered. Read more

Struct tor_rtmock::io::LocalStream

Implementations

impl LocalStream

pub async fn send_err(&mut self, kind: ErrorKind)

Trait Implementations

impl AsyncRead for LocalStream

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

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

impl AsyncWrite for LocalStream

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

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

fn poll_close(self: Pin<&mut Self>, cx: &mut Context<'_>) -> Poll<IoResult<()>>

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

impl TlsConnector<LocalStream> for MockTlsConnector

type Conn = MockTlsStream

fn negotiate_unvalidated<'life0, 'life1, 'async_trait>( &'life0 self, stream: LocalStream, _sni_hostname: &'life1 str) -> Pin<Box<dyn Future<Output = IoResult<MockTlsStream>> + Send + 'async_trait>> where 'life0: 'async_trait, 'life1: 'async_trait, Self: 'async_trait,

impl TlsProvider<LocalStream> for MockNetProvider

type Connector = MockTlsConnector

type TlsStream = MockTlsStream

fn tls_connector(&self) -> MockTlsConnector

impl<R: Runtime> TlsProvider<LocalStream> for MockNetRuntime<R>

type Connector = <MockNetProvider as TlsProvider<LocalStream>>::Connector

type TlsStream = <MockNetProvider as TlsProvider<LocalStream>>::TlsStream

fn tls_connector(&self) -> Self::Connector

Auto Trait Implementations

impl !RefUnwindSafe for LocalStream

impl Send for LocalStream

impl Sync for LocalStream

impl Unpin for LocalStream

impl !UnwindSafe for LocalStream

Blanket Implementations

impl<T> Any for T where T: 'static + ?Sized,

fn type_id(&self) -> TypeId

impl<R> AsyncReadExt for R where R: AsyncRead + ?Sized,

fn chain<R>(self, next: R) -> Chain<Self, R> where R: AsyncRead,

fn read(&'a mut self, buf: &'a mut [u8]) -> Read<'a, Self> where Self: Unpin,

fn read_vectored( &'a mut self, bufs: &'a mut [IoSliceMut<'a>]) -> ReadVectored<'a, Self> where Self: Unpin,

fn read_exact(&'a mut self, buf: &'a mut [u8]) -> ReadExact<'a, Self> where Self: Unpin,

fn read_to_end( &'a mut self, buf: &'a mut Vec<u8, Global>) -> ReadToEnd<'a, Self> where Self: Unpin,

fn read_to_string(&'a mut self, buf: &'a mut String) -> ReadToString<'a, Self> where Self: Unpin,

fn split(self) -> (ReadHalf<Self>, WriteHalf<Self>) where Self: AsyncWrite,

fn take(self, limit: u64) -> Take<Self>

impl<R> AsyncReadExt for R where R: AsyncRead + ?Sized,

fn read(&'a mut self, buf: &'a mut [u8]) -> ReadFuture<'a, Self> where Self: Unpin,

fn read_vectored( &'a mut self, bufs: &'a mut [IoSliceMut<'a>]) -> ReadVectoredFuture<'a, Self> where Self: Unpin,

fn read_to_end( &'a mut self, buf: &'a mut Vec<u8, Global>) -> ReadToEndFuture<'a, Self> where Self: Unpin,

fn read_to_string( &'a mut self, buf: &'a mut String) -> ReadToStringFuture<'a, Self> where Self: Unpin,

fn read_exact(&'a mut self, buf: &'a mut [u8]) -> ReadExactFuture<'a, Self> where Self: Unpin,

fn take(self, limit: u64) -> Take<Self>

fn bytes(self) -> Bytes<Self>

fn chain<R>(self, next: R) -> Chain<Self, R> where R: AsyncRead,

fn boxed_reader<'a>(self) -> Pin<Box<dyn AsyncRead + Send + 'a, Global>> where Self: 'a + Send,

impl<W> AsyncWriteExt for W where W: AsyncWrite + ?Sized,

fn flush(&mut self) -> Flush<'_, Self> where Self: Unpin,

fn close(&mut self) -> Close<'_, Self> where Self: Unpin,

fn write(&'a mut self, buf: &'a [u8]) -> Write<'a, Self> where Self: Unpin,

fn write_vectored( &'a mut self, bufs: &'a [IoSlice<'a>]) -> WriteVectored<'a, Self> where Self: Unpin,

fn write_all(&'a mut self, buf: &'a [u8]) -> WriteAll<'a, Self> where Self: Unpin,

fn into_sink<Item>(self) -> IntoSink<Self, Item> where Item: AsRef<[u8]>,

impl<W> AsyncWriteExt for W where W: AsyncWrite + ?Sized,

fn write(&'a mut self, buf: &'a [u8]) -> WriteFuture<'a, Self> where Self: Unpin,

fn write_vectored( &'a mut self, bufs: &'a [IoSlice<'a>]) -> WriteVectoredFuture<'a, Self> where Self: Unpin,

fn write_all(&'a mut self, buf: &'a [u8]) -> WriteAllFuture<'a, Self> where Self: Unpin,

fn flush(&mut self) -> FlushFuture<'_, Self> where Self: Unpin,

fn close(&mut self) -> CloseFuture<'_, Self> where Self: Unpin,

fn boxed_writer<'a>(self) -> Pin<Box<dyn AsyncWrite + Send + 'a, Global>> where Self: 'a + Send,

impl<T> Borrow<T> for T where T: ?Sized,

fn borrow(&self) -> &T

impl<T> BorrowMut<T> for T where T: ?Sized,

fn borrow_mut(&mut self) -> &mut T

impl<T> From<T> for T

fn from(t: T) -> T

impl<T> FuturesAsyncReadCompatExt for T where T: AsyncRead,

fn compat(self) -> Compat<Self>

impl<T> FuturesAsyncWriteCompatExt for T where T: AsyncWrite,

fn compat_write(self) -> Compat<Self>

impl<T> Instrument for T

fn instrument(self, span: Span) -> Instrumented<Self>

fn in_current_span(self) -> Instrumented<Self>

impl<T, U> Into<U> for T where U: From<T>,

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

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

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

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

fn negotiate_unvalidated<'life0, 'life1, 'async_trait>(
&'life0 self,
stream: LocalStream,
_sni_hostname: &'life1 str
) -> Pin<Box<dyn Future<Output = IoResult<MockTlsStream>> + Send + 'async_trait>> where
'life0: 'async_trait,
'life1: 'async_trait,
Self: 'async_trait,

impl<T> Any for T where
T: 'static + ?Sized,

impl<R> AsyncReadExt for R where
R: AsyncRead + ?Sized,

fn chain<R>(self, next: R) -> Chain<Self, R> where
R: AsyncRead,

fn read(&'a mut self, buf: &'a mut [u8 ]) -> Read<'a, Self> where
Self: Unpin,

fn read_vectored(
&'a mut self,
bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectored<'a, Self> where
Self: Unpin,

fn read_exact(&'a mut self, buf: &'a mut [u8 ]) -> ReadExact<'a, Self> where
Self: Unpin,

fn read_to_end(
&'a mut self,
buf: &'a mut Vec<u8, Global>
) -> ReadToEnd<'a, Self> where
Self: Unpin,

fn read_to_string(&'a mut self, buf: &'a mut String) -> ReadToString<'a, Self> where
Self: Unpin,

fn split(self) -> (ReadHalf<Self>, WriteHalf<Self>) where
Self: AsyncWrite,

impl<R> AsyncReadExt for R where
R: AsyncRead + ?Sized,

fn read(&'a mut self, buf: &'a mut [u8 ]) -> ReadFuture<'a, Self> where
Self: Unpin,

fn read_vectored(
&'a mut self,
bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectoredFuture<'a, Self> where
Self: Unpin,

fn read_to_end(
&'a mut self,
buf: &'a mut Vec<u8, Global>
) -> ReadToEndFuture<'a, Self> where
Self: Unpin,

fn read_to_string(
&'a mut self,
buf: &'a mut String
) -> ReadToStringFuture<'a, Self> where
Self: Unpin,

fn read_exact(&'a mut self, buf: &'a mut [u8 ]) -> ReadExactFuture<'a, Self> where
Self: Unpin,

fn chain<R>(self, next: R) -> Chain<Self, R> where
R: AsyncRead,

fn boxed_reader<'a>(self) -> Pin<Box<dyn AsyncRead + Send + 'a, Global>> where
Self: 'a + Send,

impl<W> AsyncWriteExt for W where
W: AsyncWrite + ?Sized,

fn flush(&mut self) -> Flush<'_, Self> where
Self: Unpin,

fn close(&mut self) -> Close<'_, Self> where
Self: Unpin,

fn write(&'a mut self, buf: &'a [u8 ]) -> Write<'a, Self> where
Self: Unpin,

fn write_vectored(
&'a mut self,
bufs: &'a [IoSlice<'a>]
) -> WriteVectored<'a, Self> where
Self: Unpin,

fn write_all(&'a mut self, buf: &'a [u8 ]) -> WriteAll<'a, Self> where
Self: Unpin,

fn into_sink<Item>(self) -> IntoSink<Self, Item> where
Item: AsRef<[u8 ]>,

impl<W> AsyncWriteExt for W where
W: AsyncWrite + ?Sized,

fn write(&'a mut self, buf: &'a [u8 ]) -> WriteFuture<'a, Self> where
Self: Unpin,

fn write_vectored(
&'a mut self,
bufs: &'a [IoSlice<'a>]
) -> WriteVectoredFuture<'a, Self> where
Self: Unpin,

fn write_all(&'a mut self, buf: &'a [u8 ]) -> WriteAllFuture<'a, Self> where
Self: Unpin,

fn flush(&mut self) -> FlushFuture<'_, Self> where
Self: Unpin,

fn close(&mut self) -> CloseFuture<'_, Self> where
Self: Unpin,

fn boxed_writer<'a>(self) -> Pin<Box<dyn AsyncWrite + Send + 'a, Global>> where
Self: 'a + Send,

impl<T> Borrow<T> for T where
T: ?Sized,

impl<T> BorrowMut<T> for T where
T: ?Sized,

impl<T> FuturesAsyncReadCompatExt for T where
T: AsyncRead,

impl<T> FuturesAsyncWriteCompatExt for T where
T: AsyncWrite,

impl<T, U> Into<U> for T where
U: From<T>,

impl<T> ReadExt for T where
T: AsyncRead + ?Sized,

fn read(&'a mut self, buf: &'a mut [u8 ]) -> ReadFuture<'a, Self> where
Self: Unpin,

fn read_vectored(
&'a mut self,
bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectoredFuture<'a, Self> where
Self: Unpin,

fn read_to_end(
&'a mut self,
buf: &'a mut Vec<u8, Global>
) -> ReadToEndFuture<'a, Self> where
Self: Unpin,

fn read_to_string(
&'a mut self,
buf: &'a mut String
) -> ReadToStringFuture<'a, Self> where
Self: Unpin,

fn read_exact(&'a mut self, buf: &'a mut [u8 ]) -> ReadExactFuture<'a, Self> where
Self: Unpin,

fn chain<R>(self, next: R) -> Chain<Self, R> where
R: AsyncRead,

impl<T, U> TryFrom<U> for T where
U: Into<T>,

impl<T, U> TryInto<U> for T where
U: TryFrom<T>,

fn with_subscriber<S>(self, subscriber: S) -> WithDispatch<Self> where
S: Into<Dispatch>,

impl<T> WriteExt for T where
T: AsyncWrite + ?Sized,

fn write(&'a mut self, buf: &'a [u8 ]) -> WriteFuture<'a, Self> where
Self: Unpin,

fn flush(&mut self) -> FlushFuture<'_, Self> where
Self: Unpin,

fn write_vectored(
&'a mut self,
bufs: &'a [IoSlice<'a>]
) -> WriteVectoredFuture<'a, Self> where
Self: Unpin,

fn write_all(&'a mut self, buf: &'a [u8 ]) -> WriteAllFuture<'a, Self> where
Self: Unpin,

fn write_fmt(&'a mut self, fmt: Arguments<'_>) -> WriteFmtFuture<'a, Self> where
Self: Unpin,