Struct holochain::prelude::dependencies::kitsune_p2p_fetch::State

pub struct State { /* private fields */ }

The actual inner state of the FetchPool, from which items can be obtained

Implementations

impl State

pub fn push( &mut self, config: &(dyn FetchPoolConfig + 'static), args: FetchPoolPush )

Add an item to the queue. If the FetchKey does not already exist, add it to the end of the queue. If the FetchKey exists, add the new source and merge the context in, without changing the position in the queue.

pub fn iter_mut<'a>( &'a mut self, config: &'a (dyn FetchPoolConfig + 'static) ) -> StateIter<'a>

Access queue items through mutable iteration. Items accessed will be moved to the end of the queue.

Only items whose last_fetch is more than interval ago will be returned.

pub fn remove(&mut self, key: &FetchKey) -> Option<FetchPoolItem>

When an item has been successfully fetched, we can remove it from the queue.

Trait Implementations

impl Debug for State

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

Formats the value using the given formatter.

impl Default for State

fn default() -> State

Returns the “default value” for a type.