Struct hedwig::publish::sink::ValidatorSink [−][src]
pub struct ValidatorSink<M, V, S> { /* fields omitted */ }
publish
and sink
only.Expand description
The sink returned by the validator_sink
function
Trait Implementations
impl<M, S> Sink<M> for ValidatorSink<M, M::Validator, S> where
M: EncodableMessage,
S: Sink<(Topic, ValidatedMessage)>,
impl<M, S> Sink<M> for ValidatorSink<M, M::Validator, S> where
M: EncodableMessage,
S: Sink<(Topic, ValidatedMessage)>,
impl<'pin, M, V, S> Unpin for ValidatorSink<M, V, S> where
__ValidatorSink<'pin, M, V, S>: Unpin,
Auto Trait Implementations
impl<M, V, S> RefUnwindSafe for ValidatorSink<M, V, S> where
M: RefUnwindSafe,
S: RefUnwindSafe,
V: RefUnwindSafe,
impl<M, V, S> Send for ValidatorSink<M, V, S> where
M: Send,
S: Send,
V: Send,
impl<M, V, S> Sync for ValidatorSink<M, V, S> where
M: Sync,
S: Sync,
V: Sync,
impl<M, V, S> UnwindSafe for ValidatorSink<M, V, S> where
M: UnwindSafe,
S: UnwindSafe,
V: UnwindSafe,
Blanket Implementations
Mutably borrows from an owned value. Read more
Composes a function in front of the sink. Read more
fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F> where
F: FnMut(U) -> St,
St: Stream<Item = Result<Item, Self::Error>>,
fn with_flat_map<U, St, F>(self, f: F) -> WithFlatMap<Self, Item, U, St, F> where
F: FnMut(U) -> St,
St: Stream<Item = Result<Item, Self::Error>>,
Composes a function in front of the sink. Read more
Transforms the error returned by the sink.
Map this sink’s error to a different error type using the Into
trait. Read more
alloc
only.Adds a fixed-size buffer to the current sink. Read more
Fanout items to multiple sinks. Read more
Flush the sink, processing all pending items. Read more
A future that completes after the given item has been fully processed into the sink, including flushing. Read more
A future that completes after the given item has been received by the sink. Read more
A future that completes after the given stream has been fully processed into the sink, including flushing. Read more
Wrap this sink in an Either
sink, making it the left-hand variant
of that Either
. Read more
Wrap this stream in an Either
stream, making it the right-hand variant
of that Either
. Read more
Attaches the provided Subscriber
to this type, returning a
WithDispatch
wrapper. Read more
Attaches the current default Subscriber
to this type, returning a
WithDispatch
wrapper. Read more