qubit_http/sse/
mod.rs

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

qubit_http/sse/
mod.rs
