pub fn create_chunked_stream( data: Vec<Value>, config: ChunkConfig, ) -> Pin<Box<dyn Stream<Item = Result<Vec<Value>, RuleError>> + Send>>
Create a chunked stream from a large dataset