Function hedwig::publish::sink::validator_sink[−][src]

pub fn validator_sink<M, S>(
    validator: M::Validator, 
    destination_sink: S
) -> ValidatorSink<M, M::Validator, S> where
    M: EncodableMessage,
    S: Sink<(Topic, ValidatedMessage)>,

This is supported on crate features publish and sink only.

Expand description

A sink which ingests messages, validates them with the given validator, then forwards them to the given destination sink.