/// Process any Entry items that have been published by the Historian.
/// continuosly broadcast blobs of entries out
Process any Entry items that have been published by the Historian.
continuosly broadcast blobs of entries out
Process any Entry items that have been published by the Historian . continuosly broadcast blobs of entries out
fn run_sync<W: Write>(
        obj: SharedSkel,
        broadcast: &streamer::BlobSender,
        blob_recycler: &packet::BlobRecycler,
        writer: &Arc<Mutex<W>>,
    ) -> Result<()> {
        let mut q = VecDeque::new();
        let list = Self::receive_all(&obj, writer)?;
        trace!("New blobs? {}", list.len());
        Self::process_entry_list_into_blobs(&list, blob_recycler, &mut q);
        if !q.is_empty() {
            broadcast.send(q)?;
        }
        Ok(())
    }
fn run_sync < W : Write > ( obj : SharedSkel , broadcast : & streamer :: BlobSender , blob_recycler : & packet :: BlobRecycler , writer : & Arc < Mutex < W > > , ) -> Result < ( ) > { let mut q = VecDeque :: new ( ) ; let list = Self :: receive_all ( & obj , writer ) ? ; trace ! ( " " list len ( ) ) ; Self :: process_entry_list_into_blobs ( & list , blob_recycler , & mut q ) ; if ! q . is_empty ( ) { broadcast . send ( q ) ? ; } Ok ( ( ) ) }
Process any Entry items that have been published by the Historian.
Process any Entry items that have been published by the Historian .
obj
SharedSkel
broadcast
&streamer::BlobSender
blob_recycler
&packet::BlobRecycler
writer
&Arc<Mutex<W>>