Struct tarantool::network::client::tcp::UnsafeSendSyncTcpStream

#[repr(transparent)]
pub struct UnsafeSendSyncTcpStream(pub TcpStream);

A wrapper around TcpStream which also implements Send & Sync.

Note that it’s actually not safe to use this stream outside the thread in which it was created, because it’s implemented on top of the tarantool’s fiber runtime. This wrapper only exists because of the cancerous Send + Sync trait bounds placed on almost all third-party async code. These bounds aren’t necessary when working with our async runtime, which is single threaded.

Tuple Fields

0: TcpStream

Trait Implementations

impl AsyncRead for UnsafeSendSyncTcpStream

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

Attempt to read from the AsyncRead into buf.

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.

impl AsyncWrite for UnsafeSendSyncTcpStream

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

Attempt to write bytes from buf into the object.

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

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

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

Attempt to close the object.

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.

impl Clone for UnsafeSendSyncTcpStream

fn clone(&self) -> UnsafeSendSyncTcpStream

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for UnsafeSendSyncTcpStream

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

Formats the value using the given formatter.

impl Send for UnsafeSendSyncTcpStream

impl Sync for UnsafeSendSyncTcpStream