pub struct IoResult {
pub bytes: u64,
pub status: StreamResult<()>,
}Expand description
Akka-style materialized IO result for Tokio-backed file and TCP byte streams.
bytes records the number of bytes successfully read or written before the
terminal status. IO failures are also propagated through the stream as
StreamError; the materialized result preserves the byte count for
partial reads/writes.
Fields§
§bytes: u64§status: StreamResult<()>Implementations§
Source§impl IoResult
impl IoResult
Sourcepub fn failed(bytes: u64, error: StreamError) -> Self
pub fn failed(bytes: u64, error: StreamError) -> Self
A failed result preserving the bytes transferred before error.
Sourcepub fn status(&self) -> StreamResult<()>
pub fn status(&self) -> StreamResult<()>
Terminal status: Ok(()) on success, Err(StreamError) on failure.
Sourcepub fn is_success(&self) -> bool
pub fn is_success(&self) -> bool
true when the transfer completed without error.
Trait Implementations§
impl Eq for IoResult
impl StructuralPartialEq for IoResult
Auto Trait Implementations§
impl Freeze for IoResult
impl RefUnwindSafe for IoResult
impl Send for IoResult
impl Sync for IoResult
impl Unpin for IoResult
impl UnsafeUnpin for IoResult
impl UnwindSafe for IoResult
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
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> Message for T
impl<T> Message for T
Source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
Convert a BoxedMessage to this concrete type
Source§fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage