Trait polkadot_node_subsystem::gen::futures::prelude::Sink
pub trait Sink<Item> {
type Error;
// Required methods
fn poll_ready(
self: Pin<&mut Self>,
cx: &mut Context<'_>,
) -> Poll<Result<(), Self::Error>>;
fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error>;
fn poll_flush(
self: Pin<&mut Self>,
cx: &mut Context<'_>,
) -> Poll<Result<(), Self::Error>>;
fn poll_close(
self: Pin<&mut Self>,
cx: &mut Context<'_>,
) -> Poll<Result<(), Self::Error>>;
}Expand description
A Sink is a value into which other values can be sent, asynchronously.
Basic examples of sinks include the sending side of:
- Channels
- Sockets
- Pipes
In addition to such “primitive” sinks, it’s typical to layer additional functionality, such as buffering, on top of an existing sink.
Sending to a sink is “asynchronous” in the sense that the value may not be sent in its entirety immediately. Instead, values are sent in a two-phase way: first by initiating a send, and then by polling for completion. This two-phase setup is analogous to buffered writing in synchronous code, where writes often succeed immediately, but internally are buffered and are actually written only upon flushing.
In addition, the Sink may be full, in which case it is not even possible
to start the sending process.
As with Future and Stream, the Sink trait is built from a few core
required methods, and a host of default methods for working in a
higher-level way. The Sink::send_all combinator is of particular
importance: you can use it to send an entire stream to a sink, which is
the simplest way to ultimately consume a stream.
Required Associated Types§
type Error
type Error
The type of value produced by the sink when an error occurs.
Required Methods§
fn poll_ready(
self: Pin<&mut Self>,
cx: &mut Context<'_>,
) -> Poll<Result<(), Self::Error>>
fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>
Attempts to prepare the Sink to receive a value.
This method must be called and return Poll::Ready(Ok(())) prior to
each call to start_send.
This method returns Poll::Ready once the underlying sink is ready to
receive data. If this method returns Poll::Pending, the current task
is registered to be notified (via cx.waker().wake_by_ref()) when poll_ready
should be called again.
In most cases, if the sink encounters an error, the sink will permanently be unable to receive items.
fn start_send(self: Pin<&mut Self>, item: Item) -> Result<(), Self::Error>
fn start_send(self: Pin<&mut Self>, item: Item) -> 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(())).
As the name suggests, this method only begins the process of sending
the item. If the sink employs buffering, the item isn’t fully processed
until the buffer is fully flushed. Since sinks are designed to work with
asynchronous I/O, the process of actually writing out the data to an
underlying object takes place asynchronously. You must use
poll_flush or poll_close in order to guarantee completion of a
send.
Implementations of poll_ready and start_send will usually involve
flushing behind the scenes in order to make room for new messages.
It is only necessary to call poll_flush if you need to guarantee that
all of the items placed into the Sink have been sent.
In most cases, if the sink encounters an error, the sink will permanently be unable to receive items.
fn poll_flush(
self: Pin<&mut Self>,
cx: &mut Context<'_>,
) -> Poll<Result<(), Self::Error>>
fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>
Flush any remaining output from this sink.
Returns Poll::Ready(Ok(())) when no buffered items remain. If this
value is returned then it is guaranteed that all previous values sent
via start_send have been flushed.
Returns Poll::Pending if there is more work left to do, in which
case the current task is scheduled (via cx.waker().wake_by_ref()) to wake up when
poll_flush should be called again.
In most cases, if the sink encounters an error, the sink will permanently be unable to receive items.
fn poll_close(
self: Pin<&mut Self>,
cx: &mut Context<'_>,
) -> Poll<Result<(), Self::Error>>
fn poll_close( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Self::Error>>
Flush any remaining output and close this sink, if necessary.
Returns Poll::Ready(Ok(())) when no buffered items remain and the sink
has been successfully closed.
Returns Poll::Pending if there is more work left to do, in which
case the current task is scheduled (via cx.waker().wake_by_ref()) to wake up when
poll_close should be called again.
If this function encounters an error, the sink should be considered to
have failed permanently, and no more Sink methods should be called.
Implementations on Foreign Types§
§impl Sink<Bytes> for Substream
impl Sink<Bytes> for Substream
type Error = SubstreamError
fn poll_ready( self: Pin<&mut Substream>, cx: &mut Context<'_>, ) -> Poll<Result<(), <Substream as Sink<Bytes>>::Error>>
fn start_send( self: Pin<&mut Substream>, item: Bytes, ) -> Result<(), <Substream as Sink<Bytes>>::Error>
fn poll_flush( self: Pin<&mut Substream>, cx: &mut Context<'_>, ) -> Poll<Result<(), <Substream as Sink<Bytes>>::Error>>
fn poll_close( self: Pin<&mut Substream>, cx: &mut Context<'_>, ) -> Poll<Result<(), <Substream as Sink<Bytes>>::Error>>
§impl<'a, Item, S, D, C, MW> Sink<Item> for RatelimitedSink<'a, Item, S, D, C, MW>
impl<'a, Item, S, D, C, MW> Sink<Item> for RatelimitedSink<'a, Item, S, D, C, MW>
type Error = <S as Sink<Item>>::Error
fn poll_ready( self: Pin<&mut RatelimitedSink<'a, Item, S, D, C, MW>>, cx: &mut Context<'_>, ) -> Poll<Result<(), <RatelimitedSink<'a, Item, S, D, C, MW> as Sink<Item>>::Error>>
fn start_send( self: Pin<&mut RatelimitedSink<'a, Item, S, D, C, MW>>, item: Item, ) -> Result<(), <RatelimitedSink<'a, Item, S, D, C, MW> as Sink<Item>>::Error>
fn poll_flush( self: Pin<&mut RatelimitedSink<'a, Item, S, D, C, MW>>, cx: &mut Context<'_>, ) -> Poll<Result<(), <RatelimitedSink<'a, Item, S, D, C, MW> as Sink<Item>>::Error>>
fn poll_close( self: Pin<&mut RatelimitedSink<'a, Item, S, D, C, MW>>, cx: &mut Context<'_>, ) -> Poll<Result<(), <RatelimitedSink<'a, Item, S, D, C, MW> as Sink<Item>>::Error>>
§impl<'a, Item, S, D, C, MW> Sink<Item> for RatelimitedStream<'a, S, D, C, MW>
impl<'a, Item, S, D, C, MW> Sink<Item> for RatelimitedStream<'a, S, D, C, MW>
Pass-through implementation for futures::Sink if the Stream also implements it.