Trait nbio::Flush

pub trait Flush: Publish {
    // Required method
    fn flush(&mut self) -> Result<(), Error>;
}

A Publish implementation that exposes a blocking flush operation.

Required Methods

fn flush(&mut self) -> Result<(), Error>

Flush all pending publish data, blocking until completion.

Object Safety

This trait is not object safe.

Implementors

impl Flush for HttpClientSession

impl Flush for TcpSession

impl Flush for WebSocketSession

impl<MapFunc, Sess, ReceivePayload> Flush for MappingReceiver<MapFunc, Sess, ReceivePayload>

where MapFunc: for<'a> Fn(Sess::ReceivePayload<'a>) -> ReceivePayload + 'static, Sess: Receive + Flush, ReceivePayload: 'static,

impl<S> Flush for LivenessSession<S>

where S: Flush + Receive + 'static,

impl<S, C> Flush for CallbackDriver<S, C>

where S: Flush + Receive, C: for<'a> Callback<S::ReceivePayload<'a>> + 'static,

impl<S, C> Flush for CallbackRefDriver<S, C>

where S: Flush + Receive, C: for<'a> CallbackRef<S::ReceivePayload<'a>> + 'static,

impl<S, DF, SF> Flush for FrameDuplex<S, DF, SF>

where S: for<'a> Publish<PublishPayload<'a> = &'a [u8]> + Flush + 'static, DF: DeserializeFrame + 'static, SF: SerializeFrame + 'static,

impl<S, F> Flush for FramePublisher<S, F>

where S: for<'a> Publish<PublishPayload<'a> = &'a [u8]> + Flush + 'static, F: SerializeFrame + 'static,

impl<S, F> Flush for HeartbeatingSession<S, F>

where S: Receive + Flush + 'static, F: for<'a> FnMut(&mut S) -> Result<HeartbeatOutcome, Error> + 'static,

impl<Sess, Payload, QueueImpl> Flush for QueueReceiver<Sess, Payload, QueueImpl>

where Sess: Flush, QueueImpl: Queue<Payload> + 'static, Payload: 'static,