Struct HoikeBroadcastHandler 

pub struct HoikeBroadcastHandler { /* private fields */ }

BroadcastHandler that processes GossipMessage broadcasts.

Implementations

impl HoikeBroadcastHandler

pub fn new(tx: Sender<GossipMessage>, verifier: Option<GossipVerifier>) -> Self

Trait Implementations

impl<T> BroadcastHandler<T> for HoikeBroadcastHandler

type Key = BroadcastKey

A unique identifier for the broadcasts this handler manages

type Error = BroadcastError

The error type that receive_item may emit. Will be wrapped by [crate::Error::CustomBroadcast].

fn receive_item( &mut self, data: &[u8], _sender: Option<&T>, ) -> Result<Option<Self::Key>, Self::Error>

Decodes a [Self::Key] from a buffer and either discards it or tells Foca to persist and disseminate it.

fn should_add_broadcast_data(&self, _member: &T) -> bool

Decides whether Foca should add broadcast data to the message it’s about to send to active member T.