Skip to main content

agentic_memory_mcp/streaming/
chunked.rs

1//! Chunked result streaming for large traversals.
2
3use serde_json::Value;
4
5/// Split a large result set into chunks for streaming.
6pub fn chunk_results(results: Vec<Value>, chunk_size: usize) -> Vec<Vec<Value>> {
7    results.chunks(chunk_size).map(|c| c.to_vec()).collect()
8}