Struct Groups 

pub struct Groups<T, E, L, C = ()> { /* private fields */ }

Available on crate feature groups only.

Processor for groups operations.

Implementations

impl<T, E, L, C> Groups<T, E, L, C>

where E: Extensions, L: LogId, C: Conditions + Serialize + for<'a> Deserialize<'a>,

pub fn new(store: SqliteStore) -> Self

Trait Implementations

impl<T, E, L, C> Processor<T> for Groups<T, E, L, C>

where T: Borrow<GroupsArgs<C>>, E: Extensions, L: LogId, C: Conditions + Serialize + for<'a> Deserialize<'a>,

type Output = (T, GroupsResult)

type Error = (T, GroupsError<C>)

async fn process(&self, input: T) -> Result<(), Self::Error>

Consumes an item for further processing.

async fn next(&self) -> Result<Self::Output, Self::Error>

Returns future with processed output whenever ready.