Struct AnyStream 

pub struct AnyStream<'a, T>(/* private fields */);

A type-erased Stream implementation that wraps stream (outputs)Stream::Output in Box<dyn Any>.

This is useful as the final layer in a stack of nested Streams that allows the top level Executor to operate without knowledge of the concrete output types.

From a performance perspective, this is usually fine since

1. Individual Stream operations are typically expensive relative to the cost of boxing.
2. Many concrete Stream implementations will use the same Executor implementation. Thus, boxing can help reduce code bloat without significant performance impact.

Implementations

impl<'a, T> AnyStream<'a, T>

pub fn new(stream: &'a mut T) -> Self

Wrap stream in an AnyStream.

Trait Implementations

impl<'a, T: Debug> Debug for AnyStream<'a, T>

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

Formats the value using the given formatter.

impl<A, T> Stream<A> for AnyStream<'_, T>

where A: Arguments, T: Stream<A>,

type Output = Box<dyn Any>

Output type for all operations. The 'static is to allow results to be aggregated in Any for type erasure in higher level Executors.

fn search(&mut self, args: A::Search<'_>) -> Result<Self::Output>

Perform a search operation.

fn insert(&mut self, args: A::Insert<'_>) -> Result<Self::Output>

Perform an insert operation.

fn replace(&mut self, args: A::Replace<'_>) -> Result<Self::Output>

Perform a replace operation.

fn delete(&mut self, args: A::Delete<'_>) -> Result<Self::Output>

Perform a delete operation.

fn maintain(&mut self, args: A::Maintain<'_>) -> Result<Self::Output>

Perform a maintain operation.

fn needs_maintenance(&mut self) -> bool

Indicate whether or not maintenance is needed. Executor implementations are responsible periodically checking this.