Function make_chunked_store

datafusion/datasource-json/src/mod.rs:49–60

Seed a fresh `InMemory` store with `data` and wrap it in a [`ChunkedStore`] that splits every GET response into `chunk_size`-byte pieces.

(
        data: &[u8],
        chunk_size: usize,
    )

    /// [`ChunkedStore`] that splits every GET response into `chunk_size`-byte
    /// pieces.
    pub async fn make_chunked_store(
        data: &[u8],
        chunk_size: usize,
    ) -> (Arc<dyn ObjectStore>, Path) {
        let inner = Arc::new(InMemory::new());
        let path = Path::from("test");
        inner
            .put(&path, PutPayload::from(Bytes::copy_from_slice(data)))
            .await
            .unwrap();
        (Arc::new(ChunkedStore::new(inner, chunk_size)), path)
    }
}