pub struct Orderer<S, T, E> { /* private fields */ }Available on crate feature
orderer only.Implementations§
Trait Implementations§
Source§impl<S, T, E> Processor<T> for Orderer<S, T, E>where
S: Transaction + OrdererStore<Hash> + OperationStore<Operation<E>, Hash> + ProcessorStore<T::Metadata>,
T: OrdererMetadata<E> + Borrow<OrdererArgs> + Digest<Hash>,
E: Extensions,
impl<S, T, E> Processor<T> for Orderer<S, T, E>where
S: Transaction + OrdererStore<Hash> + OperationStore<Operation<E>, Hash> + ProcessorStore<T::Metadata>,
T: OrdererMetadata<E> + Borrow<OrdererArgs> + Digest<Hash>,
E: Extensions,
Auto Trait Implementations§
impl<S, T, E> !Freeze for Orderer<S, T, E>
impl<S, T, E> !RefUnwindSafe for Orderer<S, T, E>
impl<S, T, E> !Sync for Orderer<S, T, E>
impl<S, T, E> Forget for Orderer<S, T, E>
impl<S, T, E> Send for Orderer<S, T, E>where
Mutex<CausalOrderer<Hash, S>>: Send,
S: Send,
RefCell<VecDeque<(T, OrdererResult)>>: Send,
PhantomData<E>: Send,
impl<S, T, E> Unpin for Orderer<S, T, E>where
Mutex<CausalOrderer<Hash, S>>: Unpin,
S: Unpin,
RefCell<VecDeque<(T, OrdererResult)>>: Unpin,
PhantomData<E>: Unpin,
impl<S, T, E> UnsafeUnpin for Orderer<S, T, E>where
Mutex<CausalOrderer<Hash, S>>: UnsafeUnpin,
S: UnsafeUnpin,
RefCell<VecDeque<(T, OrdererResult)>>: UnsafeUnpin,
PhantomData<E>: UnsafeUnpin,
impl<S, T, E> UnwindSafe for Orderer<S, T, E>where
Mutex<CausalOrderer<Hash, S>>: UnwindSafe,
S: UnwindSafe,
RefCell<VecDeque<(T, OrdererResult)>>: UnwindSafe,
PhantomData<E>: UnwindSafe,
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> 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<P, T> ProcessorExt<T> for Pwhere
T: 'static,
P: Processor<T> + 'static,
impl<P, T> ProcessorExt<T> for Pwhere
T: 'static,
P: Processor<T> + 'static,
Source§fn into_stream<S: Stream<Item = T>>(
self,
input_stream: S,
) -> ProcessorStream<Self, S, T>where
Self: Sized,
fn into_stream<S: Stream<Item = T>>(
self,
input_stream: S,
) -> ProcessorStream<Self, S, T>where
Self: Sized,
Converts this processor into a
Stream that takes an input stream and yields the
processor’s output items.