Commit 9c932514 authored by Dominik Charousset's avatar Dominik Charousset

Fix buffer_writer_impl::dispose

parent 5d1802d8
...@@ -367,7 +367,14 @@ public: ...@@ -367,7 +367,14 @@ public:
void dispose() override { void dispose() override {
CAF_LOG_TRACE(""); CAF_LOG_TRACE("");
on_complete(); if (sub_) {
sub_.cancel();
sub_ = nullptr;
}
if (buf_) {
buf_->close();
buf_ = nullptr;
}
} }
bool disposed() const noexcept override { bool disposed() const noexcept 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