Struct work_queue::WorkSender

source ·
pub struct WorkSender<K, C, O> { /* private fields */ }
Expand description

A clonable handle to the work queue. When all clones of WorkSender are dropped, the queue will process all remaining requests and terminate its output stream.

Implementations§

source§

impl<K, C, O> WorkSender<K, C, O>where K: Clone + Eq + Hash, C: TryMerge, O: Clone,

source

pub fn push( &self, key: K, context: C ) -> impl Future<Output = Result<O, Closed>>

Enqueue the given key to be processed by a worker, or attach to an existing request to process this key.

source

pub fn push_all( &self, entries: impl Iterator<Item = (K, C)> ) -> impl Iterator<Item = impl Future<Output = Result<O, Closed>>>

Enqueue all the given keys to be processed by a worker, merging them with existing known tasks if possible, returning an iterator of the futures that will resolve to the results of processing the keys.

This method is similar to, but more efficient than, mapping an iterator to WorkSender::push.

Trait Implementations§

source§

impl<K, C, O> Clone for WorkSender<K, C, O>

source§

fn clone(&self) -> Self

Returns a copy of the value. Read more
1.0.0 · source§

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

Performs copy-assignment from source. Read more
source§

impl<K, C, O> Debug for WorkSender<K, C, O>

source§

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

Formats the value using the given formatter. Read more

Auto Trait Implementations§

§

impl<K, C, O> !RefUnwindSafe for WorkSender<K, C, O>

§

impl<K, C, O> Send for WorkSender<K, C, O>where C: Send, K: Send, O: Send + Sync,

§

impl<K, C, O> Sync for WorkSender<K, C, O>where C: Send, K: Send, O: Send + Sync,

§

impl<K, C, O> Unpin for WorkSender<K, C, O>

§

impl<K, C, O> !UnwindSafe for WorkSender<K, C, O>

Blanket Implementations§

source§

impl<T> Any for Twhere T: 'static + ?Sized,

source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
source§

impl<T> Borrow<T> for Twhere T: ?Sized,

const: unstable · source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
source§

impl<T> BorrowMut<T> for Twhere T: ?Sized,

const: unstable · source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
source§

impl<T> From<T> for T

const: unstable · source§

fn from(t: T) -> T

Returns the argument unchanged.

source§

impl<T, U> Into<U> for Twhere U: From<T>,

const: unstable · source§

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source§

impl<T> ToOwned for Twhere T: Clone,

§

type Owned = T

The resulting type after obtaining ownership.
source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
source§

impl<T, U> TryFrom<U> for Twhere U: Into<T>,

§

type Error = Infallible

The type returned in the event of a conversion error.
const: unstable · source§

fn try_from(value: U) -> Result<T, <T as TryFrom<U>>::Error>

Performs the conversion.
source§

impl<T, U> TryInto<U> for Twhere U: TryFrom<T>,

§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
const: unstable · source§

fn try_into(self) -> Result<U, <U as TryFrom<T>>::Error>

Performs the conversion.