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§
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