MCPcopy Create free account
hub / github.com/apache/arrow-rs / fetch_bytes

Method fetch_bytes

arrow-avro/src/reader/async_reader/mod.rs:248–251  ·  view source on GitHub ↗

The forbid question mark thing shouldn't apply here, as it is within the future, so exported this to a separate function.

(mut reader: R, range: Range<u64>)

Source from the content-addressed store, hash-verified

246 // The forbid question mark thing shouldn't apply here, as it is within the future,
247 // so exported this to a separate function.
248 async fn fetch_bytes(mut reader: R, range: Range<u64>) -> Result<(R, Bytes), AvroError> {
249 let data = reader.get_bytes(range).await?;
250 Ok((reader, data))
251 }
252
253 #[forbid(clippy::question_mark_used)]
254 fn read_next(&mut self, cx: &mut Context<'_>) -> Poll<Option<Result<RecordBatch, AvroError>>> {

Callers

nothing calls this directly

Calls 1

get_bytesMethod · 0.45

Tested by

no test coverage detected