Commit 0229c9d6 authored by Dominik Charousset's avatar Dominik Charousset

Allow overriding of stream source/stage functions

parent b48a9f43
...@@ -37,11 +37,11 @@ public: ...@@ -37,11 +37,11 @@ public:
~stream_source() override; ~stream_source() override;
bool done() const final; bool done() const override;
error downstream_demand(strong_actor_ptr& hdl, size_t value) final; error downstream_demand(strong_actor_ptr& hdl, size_t value) override;
void abort(strong_actor_ptr& cause, const error& reason) final; void abort(strong_actor_ptr& cause, const error& reason) override;
inline abstract_downstream& out() { inline abstract_downstream& out() {
return *out_ptr_; return *out_ptr_;
......
...@@ -39,13 +39,13 @@ public: ...@@ -39,13 +39,13 @@ public:
// -- overrides -------------------------------------------------------------- // -- overrides --------------------------------------------------------------
bool done() const final; bool done() const override;
void abort(strong_actor_ptr&, const error&) final; void abort(strong_actor_ptr&, const error&) override;
error downstream_demand(strong_actor_ptr&, size_t) final; error downstream_demand(strong_actor_ptr&, size_t) override;
error upstream_batch(strong_actor_ptr&, size_t, message&) final; error upstream_batch(strong_actor_ptr&, size_t, message&) override;
void last_upstream_closed(); void last_upstream_closed();
......
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