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

Method is_closed

cpp/src/arrow/util/async_generator.h:926–934  ·  view source on GitHub ↗

Return whether the generator was closed or destroyed.

Source from the content-addressed store, hash-verified

924
925 /// Return whether the generator was closed or destroyed.
926 bool is_closed() const {
927 auto state = weak_state_.lock();
928 if (!state) {
929 // Generator was destroyed
930 return true;
931 }
932 auto lock = state->mutex.Lock();
933 return state->finished;
934 }
935
936 private:
937 const std::weak_ptr<State> weak_state_;

Callers 2

DoDiscoveryMethod · 0.80
TESTFunction · 0.80

Calls 1

LockMethod · 0.45

Tested by 1

TESTFunction · 0.64