Struct HyperHttpConnection

pub struct HyperHttpConnection { /* private fields */ }

An HTTP connection using the Hyper library and Tokio runtime.

HyperHttpConnection wraps a synchronous-style API on top of an async hyper client, implementing the embedded_svc::http::client::Connection trait.

Example

use embedded_svc::http::client::Client;
use native_svc::HyperHttpConnection;

let conn = HyperHttpConnection::new().unwrap();
let mut client = Client::wrap(conn);
let mut request = client.get("https://example.com").unwrap();
let mut response = request.submit().unwrap();
// read, process, etc.

Implementations

impl HyperHttpConnection

pub fn new() -> Result<Self, HyperError>

Creates a new HyperHttpConnection instance.

Initializes a Tokio runtime, a TLS-enabled Hyper client, and prepares internal buffers. Returns an error if the runtime cannot be created.

Trait Implementations

impl Connection for HyperHttpConnection

fn initiate_request<'a>( &'a mut self, method: Method, uri: &'a str, headers: &'a [(&'a str, &'a str)], ) -> Result<(), Self::Error>

Begins constructing an HTTP request with method, URI, and headers.

fn is_request_initiated(&self) -> bool

Returns true if a request has been initiated.

fn initiate_response(&mut self) -> Result<(), Self::Error>

Sends the initiated request and stores the response.

fn is_response_initiated(&self) -> bool

Returns true if a response has been received.

fn split(&mut self) -> (&Self::Headers, &mut Self::Read)

Splits the connection into its header and body parts.

fn raw_connection(&mut self) -> Result<&mut Self::RawConnection, Self::Error>

Returns a mutable reference to the raw connection.

type Headers = HyperHttpConnection

type Read = HyperHttpConnection

type RawConnectionError = HyperError

type RawConnection = HyperHttpConnection

impl Default for HyperHttpConnection

fn default() -> Self

Provides a default instance, panicking on failure.

Equivalent to calling HyperHttpConnection::new().unwrap().

impl ErrorType for HyperHttpConnection

type Error = HyperError

The error type returned by this connection.

impl Headers for HyperHttpConnection

fn header(&self, name: &str) -> Option<&str>

Retrieves a header value by name from the last response, if set.

fn content_type(&self) -> Option<&str>

fn content_len(&self) -> Option<u64>

fn content_encoding(&self) -> Option<&str>

fn transfer_encoding(&self) -> Option<&str>

fn host(&self) -> Option<&str>

fn connection(&self) -> Option<&str>

fn cache_control(&self) -> Option<&str>

fn upgrade(&self) -> Option<&str>

impl Read for HyperHttpConnection

fn read(&mut self, buffer: &mut [u8]) -> Result<usize, Self::Error>

Reads data from the internal buffer, loading the response body if needed. Returns Ok(0) on EOF.

fn read_exact( &mut self, buf: &mut [u8], ) -> Result<(), ReadExactError<Self::Error>>

Read the exact number of bytes required to fill buf.

impl Status for HyperHttpConnection

fn status(&self) -> u16

Returns the HTTP status code of the last response, or 500 if none.

fn status_message(&self) -> Option<&str>

Returns the reason phrase of the last response status, if available.

impl Write for HyperHttpConnection

fn write(&mut self, buf: &[u8]) -> Result<usize, HyperError>

Buffers data to be sent in the request body.

fn flush(&mut self) -> Result<(), HyperError>

Finalizes the request body by replacing it with the buffered data.

fn write_all(&mut self, buf: &[u8]) -> Result<(), Self::Error>

Write an entire buffer into this writer.

fn write_fmt( &mut self, fmt: Arguments<'_>, ) -> Result<(), WriteFmtError<Self::Error>>

Write a formatted string into this writer, returning any error encountered.