Trait ClusterStreamExt

pub trait ClusterStreamExt: Stream {
    // Provided methods
    fn take_during(self, duration: Duration) -> TakeDuring<Self>
       where Self::Item: TimestampEvent,
             Self: TimestampSource + Sized { ... }
    fn map_errors(
        self,
        is_error: fn(&Self::Item) -> bool,
    ) -> MapErrors<Self, Self::Item>
       where Self: Sized { ... }
    fn try_any_with_rust<F>(self, f: F) -> TryAnyWithRustNode<Self, F> 
       where Self: Sized + TryStream,
             F: FnMut(RustNodeId, RustNodeEvent, &P2pState) -> bool { ... }
}

Provided Methods

fn take_during(self, duration: Duration) -> TakeDuring<Self>

where Self::Item: TimestampEvent, Self: TimestampSource + Sized,

Take events during specified period of time.

fn map_errors( self, is_error: fn(&Self::Item) -> bool, ) -> MapErrors<Self, Self::Item>

where Self: Sized,

Maps events to ``Result, according to the is_error` output.

fn try_any_with_rust<F>(self, f: F) -> TryAnyWithRustNode<Self, F>

where Self: Sized + TryStream, F: FnMut(RustNodeId, RustNodeEvent, &P2pState) -> bool,

Attempts to execute a predicate over an event stream and evaluate if any rust node event and state satisfy the predicate.

Implementors

impl<T> ClusterStreamExt for T

where T: Stream,