pub struct MergeReducer {
pub deep: bool,
}Expand description
Fields§
§deep: boolWhether to perform deep merge on nested objects
Implementations§
Source§impl MergeReducer
impl MergeReducer
Sourcepub fn shallow() -> MergeReducer
pub fn shallow() -> MergeReducer
Create a shallow merge reducer
Sourcepub fn deep() -> MergeReducer
pub fn deep() -> MergeReducer
Create a deep merge reducer
Trait Implementations§
Source§impl Clone for MergeReducer
impl Clone for MergeReducer
Source§fn clone(&self) -> MergeReducer
fn clone(&self) -> MergeReducer
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 MergeReducer
impl Debug for MergeReducer
Source§impl Default for MergeReducer
impl Default for MergeReducer
Source§fn default() -> MergeReducer
fn default() -> MergeReducer
Returns the “default value” for a type. Read more
Source§impl Reducer for MergeReducer
impl Reducer for MergeReducer
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,
MergeReducer: '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,
MergeReducer: '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 MergeReducer
impl RefUnwindSafe for MergeReducer
impl Send for MergeReducer
impl Sync for MergeReducer
impl Unpin for MergeReducer
impl UnsafeUnpin for MergeReducer
impl UnwindSafe for MergeReducer
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