Commit 42309315 authored by Dominik Charousset's avatar Dominik Charousset

Remove dead code

parent 0229c9d6
...@@ -52,10 +52,6 @@ public: ...@@ -52,10 +52,6 @@ public:
strong_actor_ptr& hdl, size_t initial_demand, strong_actor_ptr& hdl, size_t initial_demand,
bool redeployable); bool redeployable);
/// Handles ACK message from a downstream actor.
/// @pre `hdl != nullptr`
virtual error downstream_ack(strong_actor_ptr& hdl, int64_t batch_id);
/// Handles new demand from a downstream actor. /// Handles new demand from a downstream actor.
/// @pre `hdl != nullptr` /// @pre `hdl != nullptr`
/// @pre `new_demand > 0` /// @pre `new_demand > 0`
...@@ -79,9 +75,6 @@ public: ...@@ -79,9 +75,6 @@ public:
/// Closes an upstream. /// Closes an upstream.
virtual error close_upstream(strong_actor_ptr& hdl); virtual error close_upstream(strong_actor_ptr& hdl);
/// Pull up to `n` new data items from upstream by sending a demand message.
virtual error pull(size_t n);
// -- handler for stream-wide events ----------------------------------------- // -- handler for stream-wide events -----------------------------------------
/// Shutdown the stream due to a fatal error. /// Shutdown the stream due to a fatal error.
......
...@@ -42,12 +42,6 @@ error stream_handler::confirm_downstream(const strong_actor_ptr&, ...@@ -42,12 +42,6 @@ error stream_handler::confirm_downstream(const strong_actor_ptr&,
return sec::cannot_add_downstream; return sec::cannot_add_downstream;
} }
error stream_handler::downstream_ack(strong_actor_ptr&, int64_t) {
CAF_LOG_ERROR("Received downstream messages in "
"a stream marked as no-downstreams");
return sec::invalid_downstream;
}
error stream_handler::downstream_demand(strong_actor_ptr&, size_t) { error stream_handler::downstream_demand(strong_actor_ptr&, size_t) {
CAF_LOG_ERROR("Received downstream messages in " CAF_LOG_ERROR("Received downstream messages in "
"a stream marked as no-downstreams"); "a stream marked as no-downstreams");
...@@ -78,11 +72,6 @@ error stream_handler::close_upstream(strong_actor_ptr&) { ...@@ -78,11 +72,6 @@ error stream_handler::close_upstream(strong_actor_ptr&) {
return sec::invalid_upstream; return sec::invalid_upstream;
} }
error stream_handler::pull(size_t) {
CAF_LOG_ERROR("Cannot pull from a stream marked as no-upstreams");
return sec::invalid_upstream;
}
optional<abstract_downstream&> stream_handler::get_downstream() { optional<abstract_downstream&> stream_handler::get_downstream() {
return none; return none;
} }
......
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