Struct tk_http::client::Proto

pub struct Proto<S: Io, C: Codec<S>> { /* fields omitted */ }

A low-level HTTP/1.x client protocol handler

Note, most of the time you need some reconnection facility and/or connection pooling on top of this interface

Methods

impl<S: Io, C: Codec<S>> Proto<S, C>

fn new(conn: S, handle: &Handle, cfg: &Arc<Config>) -> Proto<S, C>

Create a new protocol implementation from a TCP connection and a config

You should use this protocol as a Sink

impl<C: Codec<TcpStream>> Proto<TcpStream, C>

fn connect_tcp(addr: SocketAddr,
               cfg: &Arc<Config>,
               handle: &Handle)
               -> Box<Future<Item=Self, Error=Error>>

A convenience method to establish connection and create a protocol instance

Trait Implementations

impl<S: Io, C: Codec<S>> Sink for Proto<S, C>

type SinkItem = C

The type of value that the sink accepts.

type SinkError = Error

The type of value produced by the sink when an error occurs.

fn start_send(&mut self,
              item: Self::SinkItem)
              -> StartSend<Self::SinkItem, Self::SinkError>

Begin the process of sending a value to the sink.

fn poll_complete(&mut self) -> Poll<(), Self::SinkError>

Make progress on all pending requests, and determine whether they have completed.

fn with<U, F, Fut>(self, f: F) -> With<Self, U, F, Fut> where F: FnMut(U) -> Fut,
        Fut: IntoFuture<Item=Self::SinkItem>,
        Fut::Error: From<Self::SinkError>

Composes a function in front of the sink.

fn buffer(self, amt: usize) -> Buffer<Self>

Adds a fixed-size buffer to the current sink.

fn flush(self) -> Flush<Self>

A future that completes when the sink has finished processing all pending requests.

fn send(self, item: Self::SinkItem) -> Send<Self>

A future that completes after the given item has been fully processed into the sink, including flushing.

fn send_all<S>(self, stream: S) -> SendAll<Self, S> where S: Stream<Item=Self::SinkItem>, Self::SinkError: From<S::Error>

A future that completes after the given stream has been fully processed into the sink, including flushing.