Struct muxrpc::RpcSink
[−]
[src]
pub struct RpcSink<W: AsyncWrite> { /* fields omitted */ }
A sink to the peer.
Trait Implementations
impl<W: AsyncWrite> Sink for RpcSink<W>
[src]
type SinkItem = Result<Value, Value>
An Err
is emitted as an error for the peer.
type SinkError = Option<Error>
The type of value produced by the sink when an error occurs.
fn poll_ready(&mut self, cx: &mut Context) -> Poll<(), Self::SinkError>
[src]
Attempts to prepare the Sink
to receive a value. Read more
fn start_send(&mut self, item: Self::SinkItem) -> Result<(), Self::SinkError>
[src]
Begin the process of sending a value to the sink. Each call to this function must be proceeded by a successful call to poll_ready
which returned Ok(Async::Ready(()))
. Read more
fn poll_flush(&mut self, cx: &mut Context) -> Poll<(), Self::SinkError>
[src]
Flush any remaining output from this sink. Read more
fn poll_close(&mut self, cx: &mut Context) -> Poll<(), Self::SinkError>
[src]
Flush any remaining output and close this sink, if necessary. Read more