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 frame_decoder;
17mod json_decoder;
18mod line_decoder;
19mod message_decoder;
20mod sse_chunk;
21mod sse_chunk_stream;
22mod sse_control;
23mod sse_json_mode;
24mod sse_message;
25mod sse_message_stream;
26mod sse_reconnect_options;
27mod sse_reconnect_runner;
28mod sse_record;
29mod sse_record_stream;
30
31pub(crate) use message_decoder::{
32    decode_messages_from_stream_with_limits,
33    decode_records_from_stream_with_limits,
34};
35pub(crate) use sse_reconnect_runner::SseReconnectRunner;
36
37pub use done_marker_policy::DoneMarkerPolicy;
38pub use sse_chunk::SseChunk;
39pub use sse_chunk_stream::SseChunkStream;
40pub use sse_json_mode::SseJsonMode;
41pub use sse_message::SseMessage;
42pub use sse_message_stream::SseMessageStream;
43pub use sse_reconnect_options::SseReconnectOptions;
44
45pub(crate) use json_decoder::decode_json_chunks_from_stream_with_limits;
46pub(crate) use sse_control::SseControl;
47pub(crate) use sse_reconnect_options::DEFAULT_SSE_MAX_RECONNECT_DELAY;
48pub(crate) use sse_record::SseRecord;
49pub(crate) use sse_record_stream::SseRecordStream;
qubit_http/sse/mod.rs

qubit_http/sse/
mod.rs
