Struct FeedFrame 

#[non_exhaustive]
pub struct FeedFrame<'a> {
    pub offset: u64,
    pub bytes: &'a [u8],
}

One decoded feed entry: the offset plus the frame’s wire bytes (envelope + offset + RESP argv — same encoding replicas consume; crate::wire::decode_frame parses it).

use kevy_replicate::feed::{FeedPosition, FeedSource};
use kevy_replicate::source::ReplicationSource;

let mut feed = FeedSource::new(1, ReplicationSource::new(1 << 20));
let set = kevy_resp::Argv::from(vec![b"SET".to_vec(), b"k".to_vec(), b"v".to_vec()]);
feed.source_mut().push_mutation(&set);
let frames = feed.read(FeedPosition::new(1, 0), 10).expect("offset 0 is buffered");
let (decoded, _) = kevy_replicate::wire::decode_frame(frames[0].bytes)?;
assert_eq!((frames[0].offset, decoded.argv), (0, set));

Fields (Non-exhaustive)

Non-exhaustive structs could have additional fields added in future. Therefore, non-exhaustive structs cannot be constructed in external crates using the traditional Struct { .. } syntax; cannot be matched against without a wildcard ..; and struct update syntax will not work.

offset: u64

Offset the source assigned at push time.

use kevy_replicate::feed::{FeedPosition, FeedSource};
use kevy_replicate::source::ReplicationSource;

let mut feed = FeedSource::new(1, ReplicationSource::new(1 << 20));
let set = kevy_resp::Argv::from(vec![b"SET".to_vec(), b"k".to_vec(), b"v".to_vec()]);
for _ in 0..3 {
    feed.source_mut().push_mutation(&set);
}
let frames = feed.read(FeedPosition::new(1, 1), 10)?;
assert_eq!(frames.iter().map(|f| f.offset).collect::<Vec<_>>(), [1, 2]);

bytes: &'a [u8]

Wire-encoded frame bytes.

use kevy_replicate::feed::{FeedPosition, FeedSource};
use kevy_replicate::source::ReplicationSource;

let mut feed = FeedSource::new(1, ReplicationSource::new(1 << 20));
let set = kevy_resp::Argv::from(vec![b"SET".to_vec(), b"k".to_vec(), b"v".to_vec()]);
feed.source_mut().push_mutation(&set);
let frames = feed.read(FeedPosition::new(1, 0), 1)?;
assert_eq!(frames[0].bytes, kevy_replicate::wire::encode_frame(0, &set));

Trait Implementations

impl<'a> Clone for FeedFrame<'a>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a> Copy for FeedFrame<'a>

impl<'a> Debug for FeedFrame<'a>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<'a> Eq for FeedFrame<'a>

impl<'a> Hash for FeedFrame<'a>

fn hash<__H: Hasher>(&self, state: &mut __H)

Feeds this value into the given Hasher.

fn hash_slice<H>(data: &[Self], state: &mut H)

where H: Hasher, Self: Sized,

Feeds a slice of this type into the given Hasher.

impl<'a> PartialEq for FeedFrame<'a>

fn eq(&self, other: &Self) -> bool

Equality operator ==.

fn ne(&self, other: &Rhs) -> bool

Inequality operator !=.

impl<'a> StructuralPartialEq for FeedFrame<'a>