qubit_http/sse/
mod.rs

1/*******************************************************************************
2 *
3 *    Copyright (c) 2025 - 2026.
4 *    Haixing Hu, Qubit Co. Ltd.
5 *
6 *    All rights reserved.
7 *
8 ******************************************************************************/
9//! # SSE Decoding
10//!
11//! SSE utilities built on top of [`HttpByteStream`](crate::HttpByteStream).
12//!
13//! # Author
14//!
15//! Haixing Hu
16
17mod done_marker_policy;
18mod event_decoder;
19mod frame_decoder;
20mod json_decoder;
21mod line_decoder;
22mod sse_chunk;
23mod sse_chunk_stream;
24mod sse_event;
25mod sse_event_stream;
26mod sse_json_mode;
27mod sse_reconnect_options;
28mod sse_reconnect_runner;
29
30pub(crate) use event_decoder::decode_events_from_stream_with_limits;
31pub(crate) use sse_reconnect_runner::SseReconnectRunner;
32
33pub use done_marker_policy::DoneMarkerPolicy;
34pub use sse_chunk::SseChunk;
35pub use sse_chunk_stream::SseChunkStream;
36pub use sse_event::SseEvent;
37pub use sse_event_stream::SseEventStream;
38pub use sse_json_mode::SseJsonMode;
39pub use sse_reconnect_options::SseReconnectOptions;
40
41pub(crate) use json_decoder::decode_json_chunks_from_stream_with_limits;
42pub(crate) use sse_reconnect_options::DEFAULT_SSE_MAX_RECONNECT_DELAY;
43
44#[cfg(coverage)]
45#[doc(hidden)]
46pub(crate) use sse_reconnect_runner::coverage_validate_sse_response_content_type;
qubit_http/sse/mod.rs

qubit_http/sse/
mod.rs
