aeronet_wt_native

A WebTransport transport implementation of aeronet, which uses the QUIC protocol under the hood to provide reliable streams and unreliable datagrams.

This transport can be used in a native app to provide a client and server transport using wtransport as the WebTransport protocol implementation. Using this requires the tokio async runtime.

Getting started

The client and server implementations can be used separately, but have a similar API surface:

• To create a client, use [create_client] and use [WebTransportClient].
• To create a server, use [create_server] and use [WebTransportServer].

The creation process will return (WebTransport*, WebTransport*Backend) - a frontend and backend object respectively. You should call listen on the backend in an async Tokio task as soon as possible to start the server, then store and use the frontend within your app to interact with the backend.

use aeronet::{Message, TryIntoBytes, TryFromBytes};
use aeronet_wt_native::{wtransport::ClientConfig, TransportStreams, SendOn, ClientStream};

fn run<C2S, S2C>()
where
    // Since we're making a client, the C2S message type must implement the outgoing traits
    // Outgoing messages must:
    // * `TryIntoBytes` - be able to be converted into `Vec<u8>`
    // * `SendOn<ClientStream>` - determine what QUIC ClientStream they are sent along
    C2S: Message + TryIntoBytes + SendOn<ClientStream>,
    // Incoming messages must:
    // * `TryFromBytes` - be able to be deserialized from a `Vec<u8>`
    S2C: Message + TryFromBytes,
{
    // the `wtransport` client config
    let config = create_client_config();
    // what QUIC streams will be opened by this connection
    // by default, zero (only datagrams are available)
    let streams = TransportStreams::default();

    let (frontend, backend) = aeronet_wt_native::create_client::<C2S, S2C>(config, streams);

    // start the backend as soon as we have an async runtime
    tokio::spawn(async move {
        backend.start().await.unwrap();
    });

    // and use the frontend throughout our app
    frontend.connect("https://echo.webtransport.day");
}
# fn create_client_config() -> ClientConfig { unimplemented!() }