hyperlane-core 22.0.6

A lightweight, high-performance, and cross-platform Rust HTTP server library built on Tokio. It simplifies modern web service development by providing built-in support for middleware, WebSocket, Server-Sent Events (SSE), and raw TCP communication. With a unified and ergonomic API across Windows, Linux, and MacOS, it enables developers to build robust, scalable, and event-driven network applications with minimal overhead and maximum flexibility.
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

use super::*;

/// Builds the transport pair one protocol request stream runs over.
///
/// The peers are carried as one value because the transport reports both ends
/// of the same connection.
///
/// # Arguments
///
/// - `RequestConfig` - The parsing limits and read timeout for the stream.
/// - `StreamPeers` - The addresses of the carrying connection.
///
/// # Returns
///
/// - `(Stream, DuplexStream)` - The pipeline's stream and the pump's read end.
pub(crate) fn build_duplex_transport(
    request_config: RequestConfig,
    peers: StreamPeers,
) -> (Stream, DuplexStream) {
    let (pipe, peer): (DuplexStream, DuplexStream) = tokio::io::duplex(PROTOCOL_STREAM_CAPACITY);
    let transport: DuplexTransport = DuplexTransport {
        pipe,
        local: Some(peers.local),
        remote: Some(peers.remote),
    };
    (
        Stream::from_transport(transport, request_config, false),
        peer,
    )
}