rskit-provider 0.2.0-alpha.3

Provider traits (request-response, stream, sink, duplex) with a tower bridge
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

use rskit_errors::AppError;

use crate::traits::{Provider, RequestResponse, Sink};
use crate::{TowerProvider, request_response_fn, sink_fn};

// ── 1. request_response_fn_executes ──────────────────────────────────────

#[tokio::test]
async fn request_response_fn_executes() {
    let provider = request_response_fn("test", |x: i32| async move { Ok(x * 2) });
    let result = provider.execute(21).await;
    assert_eq!(result.unwrap(), 42);
    assert_eq!(provider.name(), "test");
}

// ── 2. sink_fn_sends_value ────────────────────────────────────────────────

#[tokio::test]
async fn sink_fn_sends_value() {
    let sink = sink_fn("sink", |_x: i32| async move { Ok(()) });
    let result = sink.send(1).await;
    assert!(result.is_ok());
}

// ── 3. tower_provider_executes ────────────────────────────────────────────

#[tokio::test]
async fn tower_provider_executes() {
    let svc = tower::service_fn(|req: i32| async move { Ok::<i32, AppError>(req * 2) });
    let provider = TowerProvider::new("tp", svc);
    let result = provider.execute(5).await;
    assert_eq!(result.unwrap(), 10);
}