Struct MemorixTaskItemNoKey

pub struct MemorixTaskItemNoKey<P, E, D, EM, G> { /* private fields */ }

Implementations

impl<P: Serialize + DeserializeOwned, E, D, EM, G> MemorixTaskItemNoKey<P, E, D, EM, G>

pub fn new( memorix_base: MemorixBase, id: String, options: Option<MemorixTaskOptions>, ) -> Result<Self, Box<dyn Error + Sync + Send>>

impl<P: Serialize + DeserializeOwned, E: CanTaskEnqueue, D, EM, G> MemorixTaskItemNoKey<P, E, D, EM, G>

pub async fn enqueue( &mut self, payload: &P, ) -> Result<MemorixTaskItemEnqueue, Box<dyn Error + Sync + Send>>

impl<P: Serialize + DeserializeOwned, E, D: CanTaskDequeue, EM, G> MemorixTaskItemNoKey<P, E, D, EM, G>

pub async fn dequeue( &self, ) -> Result<impl Stream<Item = Result<P, Box<dyn Error + Sync + Send>>> + '_, Box<dyn Error + Sync + Send>>

impl<P: Serialize + DeserializeOwned, E, D, EM: CanTaskEmpty, G> MemorixTaskItemNoKey<P, E, D, EM, G>

pub async fn empty(&mut self) -> Result<(), Box<dyn Error + Sync + Send>>

impl<P: Serialize + DeserializeOwned, E, D, EM, G: CanTaskGetLen> MemorixTaskItemNoKey<P, E, D, EM, G>

pub async fn get_len(&mut self) -> Result<usize, Box<dyn Error + Sync + Send>>

Trait Implementations

impl<P, E, D, EM, G> Clone for MemorixTaskItemNoKey<P, E, D, EM, G>

fn clone(&self) -> Self

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.