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

Method CheckForTermination

cpp/src/arrow/util/future.h:810–820  ·  view source on GitHub ↗

Source from the content-addressed store, hash-verified

808Future<BreakValueType> Loop(Iterate iterate) {
809 struct Callback {
810 bool CheckForTermination(const Result<Control>& control_res) {
811 if (!control_res.ok()) {
812 break_fut.MarkFinished(control_res.status());
813 return true;
814 }
815 if (control_res->has_value()) {
816 break_fut.MarkFinished(**control_res);
817 return true;
818 }
819 return false;
820 }
821
822 void operator()(const Result<Control>& maybe_control) && {
823 if (CheckForTermination(maybe_control)) return;

Callers

nothing calls this directly

Calls 3

okMethod · 0.45
MarkFinishedMethod · 0.45
statusMethod · 0.45

Tested by

no test coverage detected