runa_io::traits

Trait WriteMessage

Source 
pub trait WriteMessage {
    // Required methods
    fn poll_ready(
        self: Pin<&mut Self>,
        cx: &mut Context<'_>,
    ) -> Poll<Result<(), Error>>;
    fn start_send<M>(self: Pin<&mut Self>, object_id: u32, msg: M)
       where M: Serialize + Debug;
    fn poll_flush(
        self: Pin<&mut Self>,
        cx: &mut Context<'_>,
    ) -> Poll<Result<(), Error>>;

    // Provided methods
    fn send<'a, 'b, 'c, M>(
        &'a mut self,
        object_id: u32,
        msg: M,
    ) -> Send<'c, Self, M> ⓘ
       where 'a: 'c,
             'b: 'c,
             M: Serialize + Unpin + Debug + 'b,
             Self: Unpin { ... }
    fn flush(&mut self) -> Flush<'_, Self> ⓘ
       where Self: Unpin { ... }
}
Expand description

A trait for objects that can accept messages to be sent.

This is similar to Sink, but instead of accepting only one type of Items, it accepts any type that implements Serialize.

Required Methods§

Source

fn poll_ready( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Reserve space for a message

Source

fn start_send<M>(self: Pin<&mut Self>, object_id: u32, msg: M)
where M: Serialize + Debug,

Queue a message to be sent.

§Panics

if there is not enough space in the queue, this function panics. Before calling this, you should call poll_reserve to ensure there is enough space.

Source

fn poll_flush( self: Pin<&mut Self>, cx: &mut Context<'_>, ) -> Poll<Result<(), Error>>

Flush connection

Provided Methods§

Source

fn send<'a, 'b, 'c, M>( &'a mut self, object_id: u32, msg: M, ) -> Send<'c, Self, M> ⓘ
where 'a: 'c, 'b: 'c, M: Serialize + Unpin + Debug + 'b, Self: Unpin,

Source

fn flush(&mut self) -> Flush<'_, Self> ⓘ
where Self: Unpin,

Dyn Compatibility§

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementors§