Commit 9708dba6 authored by Dominik Charousset's avatar Dominik Charousset

Fix error signaling on op::buffer

When receiving `on_complete` from the control observable, only set an
error if we have not already started to shut down.
parent 9324dc64
......@@ -142,6 +142,7 @@ public:
void fwd_on_complete(buffer_emit_t) {
control_sub_ = nullptr;
if (state_ == state::running)
err_ = make_error(sec::end_of_stream,
"buffer: unexpected end of the control stream");
shutdown();
......
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