Struct httpbis::ClientRequest

pub struct ClientRequest { /* fields omitted */ }

Reference to outgoing stream on the client side.

Implementations

impl ClientRequest

pub fn state(&self) -> SenderState

pub fn set_drop_callback<F>(&mut self, f: F) where
    F: FnMut(&mut ClientRequest) -> Result<()> + Send + 'static, 

pub fn clear_drop_callback(&mut self)

pub fn poll(&mut self, cx: &mut Context) -> Poll<Result<(), StreamDead>>

Wait for stream to be ready to accept data.

pub fn send_data(&mut self, data: Bytes) -> Result<(), SendError>

Enqueue data to outgoing stream

This operation fails if stream is in incorrect state.

The operation does not fail if stream or connection windows is not available, in that case message will be queued until peer increases window.

pub fn send_data_end_of_stream(&mut self, data: Bytes) -> Result<(), SendError>

Send last DATA frame

pub fn send_trailers(&mut self, trailers: Headers) -> Result<(), SendError>

Send trailing headers

pub fn pull_from_stream(
    &mut self,
    stream: HttpStreamAfterHeaders
) -> Result<(), SendError>

pub fn pull_bytes_from_stream<S>(&mut self, stream: S) -> Result<(), SendError> where
    S: Stream<Item = Result<Bytes>> + Send + 'static, 

pub fn reset(&mut self, error_code: ErrorCode) -> Result<(), SendError>

pub fn close(&mut self) -> Result<(), SendError>

Trait Implementations

impl Drop for ClientRequest

fn drop(&mut self)

Executes the destructor for this type.