deboa-smol 0.1.0-beta.6

A friendly rest client on top of hyper.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27

use crate::rt::stream::SmolStream;
use deboa::{
    errors::{ConnectionError, DeboaError},
    Result,
};
use smol::net::TcpStream;
use std::net::IpAddr;

pub(crate) async fn create_stream(addr: IpAddr, host: &str, port: u16) -> Result<TcpStream> {
    let tcp_stream = TcpStream::connect((addr, port)).await;
    let tcp_stream = match tcp_stream {
        Ok(tcp_stream) => tcp_stream,
        Err(e) => {
            return Err(DeboaError::Connection(ConnectionError::Tcp {
                host: host.to_string(),
                message: format!("Could not connect to server: {}", e),
            }));
        }
    };

    Ok(tcp_stream)
}

pub(crate) async fn plain_connection(addr: IpAddr, host: &str, port: u16) -> Result<SmolStream> {
    let stream = create_stream(addr, host, port).await?;
    Ok(SmolStream::Plain(stream))
}