folk-core 0.2.0

Server core for Folk PHP application server — worker pool, plugin registry
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

use folk_core::runtime::{MockRuntime, Runtime};
use serde_json::json;

#[tokio::test]
async fn mock_runtime_echoes_request() {
    let rt = MockRuntime::echo();
    let mut worker = rt.spawn().await.unwrap();

    // Ready should succeed immediately for MockRuntime.
    worker.ready().await.unwrap();

    // Execute should echo the payload back.
    let payload = json!({"hello": "world"});
    let result = worker.execute("test", payload.clone()).await.unwrap();
    assert_eq!(result, payload);
}

#[tokio::test]
async fn mock_worker_refuses_after_terminate() {
    let rt = MockRuntime::echo();
    let mut worker = rt.spawn().await.unwrap();
    worker.ready().await.unwrap();
    worker.terminate().await.unwrap();

    let result = worker.execute("test", json!("hi")).await;
    assert!(result.is_err());
}