sdforge 0.3.1

Multi-protocol SDK framework with unified macro configuration
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
34

// Copyright (c) 2026 Kirky.X
// SPDX-License-Identifier: MIT
//! Streaming module test suites.
//!
//! Tests are organized by responsibility:
//! - `stream_builder_tests`: `StreamResponse`, `StreamEvent`, and `create_stream_channel`
//!   construction, serialization, deserialization, channel behavior, and Debug impls
//! - `sse_tests`: `stream_to_sse` SSE conversion and `StreamResponse`'s `IntoResponse`
//!   HTTP SSE response impl

mod sse_tests;
mod stream_builder_tests;

use crate::streaming::StreamEvent;

// ============================================================================
// Shared test helpers — accessible by all sub-modules via `super::`
// ============================================================================

pub(super) fn create_test_data_event() -> StreamEvent<serde_json::Value> {
    StreamEvent::data(serde_json::json!({"test": "value"}))
}

pub(super) fn create_test_ping_event() -> StreamEvent<()> {
    StreamEvent::ping()
}

pub(super) fn create_test_error_event(msg: &str) -> StreamEvent<()> {
    StreamEvent::error(msg.to_string())
}

pub(super) fn create_test_complete_event() -> StreamEvent<()> {
    StreamEvent::complete()
}