Trait tokio_proto::streaming::multiplex::Transport
[−]
[src]
pub trait Transport<ReadBody>: 'static + Stream<Error=Error> + Sink<SinkError=Error> {
fn tick(&mut self) { ... }
fn cancel(&mut self, request_id: RequestId) -> Result<()> { ... }
fn poll_write_body(&mut self, id: RequestId) -> Async<()> { ... }
fn dispatching_body(&mut self, id: RequestId, body: &ReadBody) { ... }
}Additional transport details relevant to streaming, multiplexed protocols.
All methods added in this trait have default implementations.
Provided Methods
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.
fn cancel(&mut self, request_id: RequestId) -> Result<()>
Cancel interest in the exchange identified by RequestId
fn poll_write_body(&mut self, id: RequestId) -> Async<()>
Tests to see if this I/O object may accept a body frame for the given request ID
fn dispatching_body(&mut self, id: RequestId, body: &ReadBody)
Invoked before the multiplexer dispatches the body chunk to the body stream.