pub enum AuthenticatedFifo {
Sender {
inner: Sender,
peer_info: HandshakeMessage,
is_server: bool,
},
Receiver {
inner: Receiver,
peer_info: HandshakeMessage,
is_server: bool,
},
}Variants§
Implementations§
Source§impl AuthenticatedFifo
impl AuthenticatedFifo
Sourcepub fn peer_info(&self) -> &HandshakeMessage
pub fn peer_info(&self) -> &HandshakeMessage
Get peer process information
Sourcepub fn new_sender(
sender: Sender,
peer_info: HandshakeMessage,
is_server: bool,
) -> Self
pub fn new_sender( sender: Sender, peer_info: HandshakeMessage, is_server: bool, ) -> Self
Create a new sender-based AuthenticatedFifo
Sourcepub fn new_receiver(
receiver: Receiver,
peer_info: HandshakeMessage,
is_server: bool,
) -> Self
pub fn new_receiver( receiver: Receiver, peer_info: HandshakeMessage, is_server: bool, ) -> Self
Create a new receiver-based AuthenticatedFifo
Sourcepub fn is_receiver(&self) -> bool
pub fn is_receiver(&self) -> bool
Check if this is a receiver
Sourcepub fn try_read(&mut self, buf: &mut [u8]) -> Result<usize>
pub fn try_read(&mut self, buf: &mut [u8]) -> Result<usize>
Try to read data (non-blocking) - only works for Receiver
Sourcepub fn try_write(&mut self, buf: &[u8]) -> Result<usize>
pub fn try_write(&mut self, buf: &[u8]) -> Result<usize>
Try to write data (non-blocking) - only works for Sender
Sourcepub async fn readable(&self) -> Result<()>
pub async fn readable(&self) -> Result<()>
Wait for readiness - only works for appropriate variant
Sourcepub async fn read(&mut self, buf: &mut [u8]) -> Result<usize>
pub async fn read(&mut self, buf: &mut [u8]) -> Result<usize>
Read some bytes from the FIFO (async) - only works for Receiver
Sourcepub async fn read_exact(&mut self, buf: &mut [u8]) -> Result<()>
pub async fn read_exact(&mut self, buf: &mut [u8]) -> Result<()>
Read exact number of bytes (async) - only works for Receiver
Sourcepub async fn write(&mut self, buf: &[u8]) -> Result<usize>
pub async fn write(&mut self, buf: &[u8]) -> Result<usize>
Write some bytes to the FIFO (async) - only works for Sender
Sourcepub async fn write_all(&mut self, buf: &[u8]) -> Result<()>
pub async fn write_all(&mut self, buf: &[u8]) -> Result<()>
Write all bytes to the FIFO (async) - only works for Sender
Sourcepub async fn write_str(&mut self, s: &str) -> Result<()>
pub async fn write_str(&mut self, s: &str) -> Result<()>
Write a string - only works for Sender
Sourcepub async fn write_line(&mut self, s: &str) -> Result<()>
pub async fn write_line(&mut self, s: &str) -> Result<()>
Write a line (with newline) - only works for Sender
Trait Implementations§
Auto Trait Implementations§
impl !Freeze for AuthenticatedFifo
impl RefUnwindSafe for AuthenticatedFifo
impl Send for AuthenticatedFifo
impl Sync for AuthenticatedFifo
impl Unpin for AuthenticatedFifo
impl UnsafeUnpin for AuthenticatedFifo
impl UnwindSafe for AuthenticatedFifo
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