MCPcopy Create free account
hub / github.com/apache/arrow / operator()

Method operator()

cpp/src/arrow/util/async_generator_test.cc:108–115  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

106class ReentrantChecker {
107 public:
108 Future<T> operator()() {
109 if (state_->generated_unfinished_future.load()) {
110 state_->valid.store(false);
111 }
112 state_->generated_unfinished_future.store(true);
113 auto result = state_->source();
114 return result.Then(Callback{state_});
115 }
116
117 bool valid() { return state_->valid.load(); }
118

Callers

nothing calls this directly

Calls 4

storeMethod · 0.80
sourceMethod · 0.80
ThenMethod · 0.80
loadMethod · 0.45

Tested by

no test coverage detected