pub struct LastNReducer {
pub n: usize,
}Expand description
Fields§
§n: usizeMaximum number of items to keep
Implementations§
Source§impl LastNReducer
impl LastNReducer
Sourcepub fn new(n: usize) -> LastNReducer
pub fn new(n: usize) -> LastNReducer
Create a new LastN reducer
Trait Implementations§
Source§impl Clone for LastNReducer
impl Clone for LastNReducer
Source§fn clone(&self) -> LastNReducer
fn clone(&self) -> LastNReducer
Returns a duplicate of the value. Read more
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source. Read moreSource§impl Debug for LastNReducer
impl Debug for LastNReducer
Source§impl Reducer for LastNReducer
impl Reducer for LastNReducer
Source§fn reduce<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
current: Option<&'life1 Value>,
update: &'life2 Value,
) -> Pin<Box<dyn Future<Output = Result<Value, AgentError>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
LastNReducer: 'async_trait,
fn reduce<'life0, 'life1, 'life2, 'async_trait>(
&'life0 self,
current: Option<&'life1 Value>,
update: &'life2 Value,
) -> Pin<Box<dyn Future<Output = Result<Value, AgentError>> + Send + 'async_trait>>where
'life0: 'async_trait,
'life1: 'async_trait,
'life2: 'async_trait,
LastNReducer: 'async_trait,
Reduce the current value with the update value Read more
Source§fn reducer_type(&self) -> ReducerType
fn reducer_type(&self) -> ReducerType
Returns the type of this reducer
Auto Trait Implementations§
impl Freeze for LastNReducer
impl RefUnwindSafe for LastNReducer
impl Send for LastNReducer
impl Sync for LastNReducer
impl Unpin for LastNReducer
impl UnsafeUnpin for LastNReducer
impl UnwindSafe for LastNReducer
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<T> IntoEither for T
impl<T> IntoEither for T
Source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left is true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
Converts
self into a Left variant of Either<Self, Self>
if into_left(&self) returns true.
Converts self into a Right variant of Either<Self, Self>
otherwise. Read moreSource§impl<T> Message for T
impl<T> Message for T
Source§fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
fn from_boxed(m: BoxedMessage) -> Result<Self, BoxedDowncastErr>
Convert a BoxedMessage to this concrete type
Source§fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
fn box_message(self, pid: &ActorId) -> Result<BoxedMessage, BoxedDowncastErr>
Convert this message to a BoxedMessage