MCPcopy Create free account
hub / github.com/apache/arrow / ReadAsync

Method ReadAsync

cpp/src/arrow/io/interfaces.cc:166–172  ·  view source on GitHub ↗

Default ReadAsync() implementation: simply issue the read on the context's executor

Source from the content-addressed store, hash-verified

164
165// Default ReadAsync() implementation: simply issue the read on the context's executor
166Future<std::shared_ptr<Buffer>> RandomAccessFile::ReadAsync(const IOContext& ctx,
167 int64_t position,
168 int64_t nbytes) {
169 auto self = std::dynamic_pointer_cast<RandomAccessFile>(shared_from_this());
170 return DeferNotOk(internal::SubmitIO(
171 ctx, [self, position, nbytes] { return self->ReadAt(position, nbytes); }));
172}
173
174Future<std::shared_ptr<Buffer>> RandomAccessFile::ReadAsync(int64_t position,
175 int64_t nbytes) {

Callers 1

interfaces.ccFile · 0.45

Calls 4

ReadAtMethod · 0.95
DeferNotOkFunction · 0.85
SubmitIOFunction · 0.85
io_contextFunction · 0.85

Tested by

no test coverage detected