Struct memsocket::MemorySocket
source · pub struct MemorySocket { /* private fields */ }
Expand description
An in-memory stream between two local sockets.
A MemorySocket
can either be created by connecting to an endpoint, via the
connect
method, or by accepting a connection from a listener.
It can be read or written to using the AsyncRead
, AsyncWrite
, and related
extension traits in futures::io
.
Examples
use futures::prelude::*;
use memsocket::MemorySocket;
let (mut socket_a, mut socket_b) = MemorySocket::new_pair();
socket_a.write_all(b"stormlight").await?;
socket_a.flush().await?;
let mut buf = [0; 10];
socket_b.read_exact(&mut buf).await?;
assert_eq!(&buf, b"stormlight");
Implementations§
source§impl MemorySocket
impl MemorySocket
sourcepub fn new_pair() -> (Self, Self)
pub fn new_pair() -> (Self, Self)
Construct both sides of an in-memory socket.
Examples
use memsocket::MemorySocket;
let (socket_a, socket_b) = MemorySocket::new_pair();
Trait Implementations§
source§impl AsyncRead for MemorySocket
impl AsyncRead for MemorySocket
source§impl AsyncWrite for MemorySocket
impl AsyncWrite for MemorySocket
source§fn poll_write(
self: Pin<&mut Self>,
context: &mut Context<'_>,
buf: &[u8]
) -> Poll<Result<usize>>
fn poll_write( self: Pin<&mut Self>, context: &mut Context<'_>, buf: &[u8] ) -> Poll<Result<usize>>
Attempt to write bytes from buf
into the outgoing channel.
source§fn poll_flush(
self: Pin<&mut Self>,
_context: &mut Context<'_>
) -> Poll<Result<()>>
fn poll_flush( self: Pin<&mut Self>, _context: &mut Context<'_> ) -> Poll<Result<()>>
Attempt to flush the channel. Cannot Fail.
Auto Trait Implementations§
impl !RefUnwindSafe for MemorySocket
impl Send for MemorySocket
impl Sync for MemorySocket
impl Unpin for MemorySocket
impl !UnwindSafe for MemorySocket
Blanket Implementations§
§impl<R> AsyncReadExt for Rwhere
R: AsyncRead + ?Sized,
impl<R> AsyncReadExt for Rwhere R: AsyncRead + ?Sized,
§fn chain<R>(self, next: R) -> Chain<Self, R>where
Self: Sized,
R: AsyncRead,
fn chain<R>(self, next: R) -> Chain<Self, R>where Self: Sized, R: AsyncRead,
Creates an adaptor which will chain this stream with another. Read more
§fn read<'a>(&'a mut self, buf: &'a mut [u8]) -> Read<'a, Self>where
Self: Unpin,
fn read<'a>(&'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§fn read_vectored<'a>(
&'a mut self,
bufs: &'a mut [IoSliceMut<'a>]
) -> ReadVectored<'a, Self>where
Self: Unpin,
fn read_vectored<'a>( &'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§fn read_exact<'a>(&'a mut self, buf: &'a mut [u8]) -> ReadExact<'a, Self>where
Self: Unpin,
fn read_exact<'a>(&'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§fn read_to_end<'a>(
&'a mut self,
buf: &'a mut Vec<u8, Global>
) -> ReadToEnd<'a, Self>where
Self: Unpin,
fn read_to_end<'a>( &'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§fn read_to_string<'a>(
&'a mut self,
buf: &'a mut String
) -> ReadToString<'a, Self>where
Self: Unpin,
fn read_to_string<'a>( &'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§impl<W> AsyncWriteExt for Wwhere
W: AsyncWrite + ?Sized,
impl<W> AsyncWriteExt for Wwhere W: AsyncWrite + ?Sized,
§fn flush(&mut self) -> Flush<'_, Self>where
Self: Unpin,
fn flush(&mut self) -> Flush<'_, Self>where Self: Unpin,
Creates a future which will entirely flush this
AsyncWrite
. Read more§fn close(&mut self) -> Close<'_, Self>where
Self: Unpin,
fn close(&mut self) -> Close<'_, Self>where Self: Unpin,
Creates a future which will entirely close this
AsyncWrite
.§fn write<'a>(&'a mut self, buf: &'a [u8]) -> Write<'a, Self>where
Self: Unpin,
fn write<'a>(&'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§fn write_vectored<'a>(
&'a mut self,
bufs: &'a [IoSlice<'a>]
) -> WriteVectored<'a, Self>where
Self: Unpin,
fn write_vectored<'a>( &'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