One scenario run over each transport on loopback: a publisher reached by the namespace route and one by PUBLISH, three subscribers of both, one of them discovering the first namespace by SUBSCRIBE_NAMESPACE. Every object reaches every subscriber and verifies against its publisher's signed receipts, which the relay checks at the door; every session's summary verifies under the relay's key and labels the relay's energy unmetered. Co-Authored-By: Claude Opus 5.5 <[email protected]>
11 lines
485 B
Rust
11 lines
485 B
Rust
//! Two publishers and three subscribers through the relay over the WebSocket fallback
|
|
//! (`draft-ietf-webtrans-http2-15` capsules, one to each message).
|
|
|
|
mod common;
|
|
|
|
#[tokio::test(flavor = "multi_thread", worker_threads = 4)]
|
|
async fn two_publishers_three_subscribers_over_websocket() {
|
|
tokio::time::timeout(std::time::Duration::from_secs(120), common::two_publishers_three_subscribers(common::Via::WebSocket))
|
|
.await
|
|
.expect("the scenario finishes in time");
|
|
}
|