We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent aa06eaa commit db90720Copy full SHA for db90720
vortex-io/src/read.rs
@@ -204,10 +204,10 @@ impl<T: VortexReadAt> VortexReadAt for InstrumentedReadAt<T> {
204
) -> BoxFuture<'static, VortexResult<ByteBuffer>> {
205
let durations = self.durations.clone();
206
let sizes = self.sizes.clone();
207
- let read = self.read.clone();
+ let read_fut = self.read.read_at(offset, length, alignment);
208
async move {
209
let _timer = durations.time();
210
- let buf = read.read_at(offset, length, alignment).await;
+ let buf = read_fut.await;
211
sizes.update(length as i64);
212
buf
213
}
0 commit comments