Commit 13a142eb authored by Dominik Charousset's avatar Dominik Charousset

Move done() implementation to stream_stage

parent 5e6c3f96
......@@ -57,11 +57,6 @@ public:
// -- implementation of virtual functions ------------------------------------
bool done() const override {
return !this->continuous() && this->pending_handshakes_ == 0
&& this->inbound_paths_.empty() && this->out_.clean();
}
void handle(inbound_path*, downstream_msg::batch& x) override {
CAF_LOG_TRACE(CAF_ARG(x));
using vec_type = std::vector<input_type>;
......
......@@ -46,6 +46,13 @@ public:
// nop
}
// -- overridden member functions --------------------------------------------
bool done() const override {
return !this->continuous() && this->inbound_paths_.empty()
&& this->pending_handshakes_ == 0 && this->out_.clean();
}
bool idle() const noexcept override {
// A stage is idle if it can't make progress on its downstream manager or
// if it has no pending work at all.
......
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