pub struct TcpStreamInboundWire<V, D>{ /* private fields */ }Implementations§
Source§impl<V, D> TcpStreamInboundWire<V, D>
impl<V, D> TcpStreamInboundWire<V, D>
pub fn new( inbound_wire: InboundWire<V, D>, stream: ReadHalf<TcpStream>, remote_addr: SocketAddr, ) -> Self
pub async fn read( &mut self, ) -> Result<(Option<Vec<u8>>, SocketAddr), InboundWireError>
Auto Trait Implementations§
impl<V, D> Freeze for TcpStreamInboundWire<V, D>
impl<V, D> !RefUnwindSafe for TcpStreamInboundWire<V, D>
impl<V, D> Send for TcpStreamInboundWire<V, D>
impl<V, D> Sync for TcpStreamInboundWire<V, D>
impl<V, D> Unpin for TcpStreamInboundWire<V, D>
impl<V, D> UnsafeUnpin for TcpStreamInboundWire<V, D>where
V: UnsafeUnpin,
D: UnsafeUnpin,
impl<V, D> !UnwindSafe for TcpStreamInboundWire<V, D>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more