Commit 1fc64885 authored by Dominik Charousset's avatar Dominik Charousset

Clean up unreachable code

parent bfbb4ad2
......@@ -214,24 +214,15 @@ private:
break;
}
}
if (out_ && inputs_.empty())
fin();
flags_.running = false;
}
void fin() {
if (!inputs_.empty()) {
for (auto& kvp : inputs_)
if (auto& sub = kvp.second->sub)
sub.dispose();
inputs_.clear();
}
if (!err_) {
out_.on_complete();
} else {
out_.on_error(err_);
if (out_ && inputs_.empty()) {
if (!err_) {
out_.on_complete();
} else {
out_.on_error(err_);
}
out_ = nullptr;
}
out_ = nullptr;
flags_.running = false;
}
/// Selects an input object by key or returns null.
......
Markdown is supported
0%
or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment