ajj 0.6.0

Simple, modern, ergonomic JSON-RPC 2.0 router built with tower and axum
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

#![cfg(feature = "ws")]

mod common;
use common::{test_router, ws_client::ws_client};

use ajj::pubsub::{Connect, ServerShutdown};
use std::net::{Ipv4Addr, SocketAddr};

const WS_SOCKET: SocketAddr =
    SocketAddr::new(std::net::IpAddr::V4(Ipv4Addr::new(127, 0, 0, 1)), 3383);
const WS_SOCKET_STR: &str = "ws://127.0.0.1:3383";

async fn serve_ws() -> ServerShutdown {
    let router = test_router();
    WS_SOCKET.serve(router).await.unwrap()
}

#[tokio::test]
async fn test_ws() {
    let _server = serve_ws().await;
    let mut client = ws_client(WS_SOCKET_STR).await;
    common::basic_tests(&mut client).await;
    common::batch_tests(&mut client).await;
}