Commit 24368f18 authored by Dominik Charousset's avatar Dominik Charousset

Remove unused flow labels

parent cc024c4a
...@@ -40,18 +40,8 @@ namespace caf { ...@@ -40,18 +40,8 @@ namespace caf {
/// Stream communication messages for handshaking, ACKing, data transmission, /// Stream communication messages for handshaking, ACKing, data transmission,
/// etc. /// etc.
struct stream_msg : tag::boxing_type { struct stream_msg : tag::boxing_type {
/// A flow label characterizes nested types.
enum flow_label {
/// Identifies content types that only flow downstream.
flows_downstream,
/// Identifies content types that only flow upstream.
flows_upstream
};
/// Initiates a stream handshake. /// Initiates a stream handshake.
struct open { struct open {
/// Allows visitors to dispatch on this tag.
static constexpr flow_label label = flows_downstream;
/// Allows the testing DSL to unbox this type automagically. /// Allows the testing DSL to unbox this type automagically.
using outer_type = stream_msg; using outer_type = stream_msg;
/// Contains a type-erased stream<T> object as first argument followed by /// Contains a type-erased stream<T> object as first argument followed by
...@@ -70,8 +60,6 @@ struct stream_msg : tag::boxing_type { ...@@ -70,8 +60,6 @@ struct stream_msg : tag::boxing_type {
/// Acknowledges a previous `open` message and finalizes a stream handshake. /// Acknowledges a previous `open` message and finalizes a stream handshake.
/// Also signalizes initial demand. /// Also signalizes initial demand.
struct ack_open { struct ack_open {
/// Allows visitors to dispatch on this tag.
static constexpr flow_label label = flows_upstream;
/// Allows the testing DSL to unbox this type automagically. /// Allows the testing DSL to unbox this type automagically.
using outer_type = stream_msg; using outer_type = stream_msg;
/// Allows actors to participate in a stream instead of the actor /// Allows actors to participate in a stream instead of the actor
...@@ -89,8 +77,6 @@ struct stream_msg : tag::boxing_type { ...@@ -89,8 +77,6 @@ struct stream_msg : tag::boxing_type {
/// Transmits stream data. /// Transmits stream data.
struct batch { struct batch {
/// Allows visitors to dispatch on this tag.
static constexpr flow_label label = flows_downstream;
/// Allows the testing DSL to unbox this type automagically. /// Allows the testing DSL to unbox this type automagically.
using outer_type = stream_msg; using outer_type = stream_msg;
/// Size of the type-erased vector<T> (used credit). /// Size of the type-erased vector<T> (used credit).
...@@ -104,8 +90,6 @@ struct stream_msg : tag::boxing_type { ...@@ -104,8 +90,6 @@ struct stream_msg : tag::boxing_type {
/// Cumulatively acknowledges received batches and signalizes new demand from /// Cumulatively acknowledges received batches and signalizes new demand from
/// a sink to its source. /// a sink to its source.
struct ack_batch { struct ack_batch {
/// Allows visitors to dispatch on this tag.
static constexpr flow_label label = flows_upstream;
/// Allows the testing DSL to unbox this type automagically. /// Allows the testing DSL to unbox this type automagically.
using outer_type = stream_msg; using outer_type = stream_msg;
/// Newly available credit. /// Newly available credit.
...@@ -116,24 +100,18 @@ struct stream_msg : tag::boxing_type { ...@@ -116,24 +100,18 @@ struct stream_msg : tag::boxing_type {
/// Orderly shuts down a stream after receiving an ACK for the last batch. /// Orderly shuts down a stream after receiving an ACK for the last batch.
struct close { struct close {
/// Allows visitors to dispatch on this tag.
static constexpr flow_label label = flows_downstream;
/// Allows the testing DSL to unbox this type automagically. /// Allows the testing DSL to unbox this type automagically.
using outer_type = stream_msg; using outer_type = stream_msg;
}; };
/// Informs a source that a sink orderly drops out of a stream. /// Informs a source that a sink orderly drops out of a stream.
struct drop { struct drop {
/// Allows visitors to dispatch on this tag.
static constexpr flow_label label = flows_upstream;
/// Allows the testing DSL to unbox this type automagically. /// Allows the testing DSL to unbox this type automagically.
using outer_type = stream_msg; using outer_type = stream_msg;
}; };
/// Propagates a fatal error from sources to sinks. /// Propagates a fatal error from sources to sinks.
struct forced_close { struct forced_close {
/// Allows visitors to dispatch on this tag.
static constexpr flow_label label = flows_downstream;
/// Allows the testing DSL to unbox this type automagically. /// Allows the testing DSL to unbox this type automagically.
using outer_type = stream_msg; using outer_type = stream_msg;
/// Reason for shutting down the stream. /// Reason for shutting down the stream.
...@@ -142,8 +120,6 @@ struct stream_msg : tag::boxing_type { ...@@ -142,8 +120,6 @@ struct stream_msg : tag::boxing_type {
/// Propagates a fatal error from sinks to sources. /// Propagates a fatal error from sinks to sources.
struct forced_drop { struct forced_drop {
/// Allows visitors to dispatch on this tag.
static constexpr flow_label label = flows_upstream;
/// Allows the testing DSL to unbox this type automagically. /// Allows the testing DSL to unbox this type automagically.
using outer_type = stream_msg; using outer_type = stream_msg;
/// Reason for shutting down the stream. /// Reason for shutting down the stream.
......
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