pub struct ReadOutcome {
pub offset: Index,
pub fragments_read: i32,
}
Expand description
Fn(&AtomicBuffer, Index, Index, &Header) -> Result<(), AeronError>; Callback for handling fragments of data being read from a log.
Handler for reading data that is coming from a log buffer. The frame will either contain a whole message or a fragment of a message to be reassembled. Messages are fragmented if greater than the frame for MTU in length. @param buffer containing the data. @param offset at which the data begins. @param length of the data in bytes. @param header representing the meta data for the data.
Fn(AeronError) Callback to indicate an exception has occurred. @param error that has occurred.
Fields§
§offset: Index
§fragments_read: i32
Trait Implementations§
Source§impl Debug for ReadOutcome
impl Debug for ReadOutcome
Source§impl Default for ReadOutcome
impl Default for ReadOutcome
Source§fn default() -> ReadOutcome
fn default() -> ReadOutcome
Returns the “default value” for a type. Read more
Auto Trait Implementations§
impl Freeze for ReadOutcome
impl RefUnwindSafe for ReadOutcome
impl Send for ReadOutcome
impl Sync for ReadOutcome
impl Unpin for ReadOutcome
impl UnwindSafe for ReadOutcome
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