nexus-async-net 0.5.1

Async WebSocket adapter for nexus-net. Tokio-compatible, zero-copy, SIMD-accelerated.
Documentation 
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
28
29
30
31
32
33
34
35

//! Async HTTP REST client — tokio adapter for nexus-net.
//!
//! Same [`RequestWriter`], same [`ResponseReader`], same zero-alloc
//! protocol layer. The only difference is `.await` on socket I/O.
//!
//! # Usage
//!
//! ```ignore
//! use nexus_net::rest::RequestWriter;
//! use nexus_net::http::ResponseReader;
//! use nexus_async_net::rest::AsyncHttpConnectionBuilder;
//!
//! let mut writer = RequestWriter::new("api.binance.com")?;
//! writer.default_header("X-API-KEY", &key)?;
//! let mut reader = ResponseReader::new(32 * 1024);
//!
//! let tls = nexus_net::tls::TlsConfig::new()?;
//! let mut conn = AsyncHttpConnectionBuilder::new()
//!     .tls(&tls)
//!     .connect("https://api.binance.com")
//!     .await?;
//!
//! let req = writer.get("/orders").query("symbol", "BTC").finish()?;
//! let resp = conn.send(req, &mut reader).await?;
//! println!("{}", resp.body_str()?);
//! ```

mod atomic_pool;
mod connection;
mod pool;

pub use crate::maybe_tls::MaybeTls;
pub use atomic_pool::{AtomicClientPool, AtomicClientPoolBuilder, AtomicClientSlot};
pub use connection::{AsyncHttpConnection, AsyncHttpConnectionBuilder};
pub use pool::{ClientPool, ClientPoolBuilder, ClientSlot};