tokio_proto::streaming::pipeline

Trait Transport

Source
pub trait Transport:
    'static
    + Stream<Error = Error>
    + Sink<SinkError = Error> {
    // Provided methods
    fn tick(&mut self) { ... }
    fn cancel(&mut self) -> Result<()> { ... }
}
Expand description

Additional transport details relevant to streaming, pipelined protocols.

All methods added in this trait have default implementations.

Provided Methods§

Source

fn tick(&mut self)

Allow the transport to do miscellaneous work (e.g., sending ping-pong messages) that is not directly connected to sending or receiving frames.

This method should be called every time the task using the transport is executing.

Source

fn cancel(&mut self) -> Result<()>

Cancel interest in the current stream

Implementations on Foreign Types§

Source§

impl<T, C> Transport for Framed<T, C>
where T: Io + 'static, C: Codec + 'static,

Implementors§