Commit f4e9dd83 authored by Dominik Charousset's avatar Dominik Charousset

Make sure the flow bridge responds to close events

parent 37b5b5c6
...@@ -54,6 +54,10 @@ public: ...@@ -54,6 +54,10 @@ public:
return buf_->has_data(); return buf_->has_data();
} }
bool has_consumer_event() const noexcept {
return buf_->has_consumer_event();
}
static ptr_type make(buf_ptr buf, socket_manager_ptr mgr, action do_wakeup) { static ptr_type make(buf_ptr buf, socket_manager_ptr mgr, action do_wakeup) {
if (buf) { if (buf) {
CAF_ASSERT(mgr); CAF_ASSERT(mgr);
......
...@@ -141,7 +141,7 @@ public: ...@@ -141,7 +141,7 @@ public:
} }
bool done_sending() override { bool done_sending() override {
return !in_ || !in_->has_data(); return !in_ || !in_->has_consumer_event();
} }
void abort(const error& reason) override { void abort(const error& reason) override {
......
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