Struct hedwig::publish::sink::PublisherSink [−][src]
pub struct PublisherSink<P, S> { /* fields omitted */ }
publish
and sink
only.Expand description
The sink returned by the publisher_sink
function
Trait Implementations
impl<P> Sink<(Topic, ValidatedMessage)> for PublisherSink<P, P::PublishStream> where
P: Publisher,
P::PublishStream: Unpin,
impl<P> Sink<(Topic, ValidatedMessage)> for PublisherSink<P, P::PublishStream> where
P: Publisher,
P::PublishStream: Unpin,
type Error = FailedMessage<P::MessageError>
type Error = FailedMessage<P::MessageError>
The type of value produced by the sink when an error occurs.
Attempts to prepare the Sink
to receive a value. Read more
fn start_send(
self: Pin<&mut Self>,
(topic, message): (Topic, ValidatedMessage)
) -> Result<(), Self::Error>
fn start_send(
self: Pin<&mut Self>,
(topic, message): (Topic, ValidatedMessage)
) -> Result<(), Self::Error>
Begin the process of sending a value to the sink.
Each call to this function must be preceded by a successful call to
poll_ready
which returned Poll::Ready(Ok(()))
. Read more
Flush any remaining output from this sink. Read more
Auto Trait Implementations
impl<P, S> !RefUnwindSafe for PublisherSink<P, S>
impl<P, S> Send for PublisherSink<P, S> where
P: Send,
S: Send,
impl<P, S> Sync for PublisherSink<P, S> where
P: Sync,
S: Sync,
impl<P, S> !UnwindSafe for PublisherSink<P, S>
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