Struct fetcher_core::source::SourceWithSharedRF

pub struct SourceWithSharedRF<F, RF>where
    F: Fetch,
    RF: ReadFilter,{
    pub source: F,
    pub rf: Option<RF>,
}

A wrapper around a Fetch that uses an external way to filter read entries, as well as a (read filter)ReadFilter

Fields

source: F

The source to fetch data from

rf: Option<RF>

The read filter that’s used to mark entries as read

Trait Implementations

impl<F, RF> Debug for SourceWithSharedRF<F, RF>where F: Fetch + Debug, RF: ReadFilter + Debug,

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

Formats the value using the given formatter.

impl<F, RF> Fetch for SourceWithSharedRF<F, RF>where F: Fetch, RF: ReadFilter,

fn fetch<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = Result<Vec<Entry>, SourceError>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Fetch all available entries from the source

impl<F, RF> MarkAsRead for SourceWithSharedRF<F, RF>where F: Fetch, RF: ReadFilter,

fn mark_as_read<'life0, 'life1, 'async_trait>( &'life0 mut self, id: &'life1 EntryId ) -> Pin<Box<dyn Future<Output = Result<(), Error>> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Mark the entry with id as read

fn set_read_only<'life0, 'async_trait>( &'life0 mut self ) -> Pin<Box<dyn Future<Output = ()> + Send + 'async_trait>>where Self: 'async_trait, 'life0: 'async_trait,

Set the current “mark as read“er to read only mode

impl<F, RF> Source for SourceWithSharedRF<F, RF>where F: Fetch, RF: ReadFilter,