We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 2b9ec8a commit 9eb6241Copy full SHA for 9eb6241
1 file changed
vortex-io/src/object_store/read_at.rs
@@ -117,10 +117,9 @@ impl VortexReadAt for ObjectStoreReadAt {
117
let allocator = Arc::clone(&self.allocator);
118
let range = offset..(offset + length as u64);
119
120
- async move {
121
- let blocking_handle = handle.clone();
+ let blocking_handle = handle.clone();
122
123
- handle
+ handle
124
.spawn_io(async move {
125
let mut buffer = allocator.allocate(length, alignment)?;
126
@@ -179,8 +178,6 @@ impl VortexReadAt for ObjectStoreReadAt {
179
178
180
Ok(BufferHandle::new_host(buffer.freeze()))
181
})
182
- .await
183
- }
184
.boxed()
185
}
186
0 commit comments