Struct SyncResponder 

pub struct SyncResponder { /* private fields */ }

Implementations

impl SyncResponder

pub fn new() -> Self

Create a new SyncResponder.

pub fn ready(&self) -> bool

Returns true if Self::poll would produce a message.

pub fn poll( &mut self, target: &mut [u8], provider: &mut impl StorageProvider, response_cache: &mut PeerCache, ) -> Result<usize, SyncError>

Write a sync message in to the target buffer. Returns the number of bytes written.

pub fn receive(&mut self, message: SyncRequestMessage) -> Result<(), SyncError>

Receive a sync message. Updates the responders state for later polling.

pub fn push( &mut self, target: &mut [u8], provider: &mut impl StorageProvider, ) -> Result<usize, SyncError>

Writes a sync push message to target for the peer. The message will contain any commands that are after the commands in response_cache.

Trait Implementations

impl Default for SyncResponder

fn default() -> SyncResponder

Returns the “default value” for a type.