Adding a passthrough mechanism for flushes in select action

stefaniereuter · stefaniereuter · commit d5885e3f0396 · 2025-01-23T19:59:10.000Z
diff --git a/src/multio/action/select/Select.cc b/src/multio/action/select/Select.cc
@@ -27,7 +27,8 @@ Select::Select(const ComponentConfiguration& compConf) :
     ChainedAction{compConf}, selectors_{MatchReduce::construct(compConf.parsedConfig())} {}
 
 void Select::executeImpl(Message msg) {
-    if (matches(msg)) {
+    //pass through action for everything that is not a field, e.g. Flush
+    if (matches(msg) || (msg.tag() != message::Message::Tag::Field)) {
         executeNext(std::move(msg));
     }
 }

Original file line number	Diff line number	Diff line change
`@@ -27,7 +27,8 @@ Select::Select(const ComponentConfiguration& compConf) :`
`27`	`27`	`ChainedAction{compConf}, selectors_{MatchReduce::construct(compConf.parsedConfig())} {}`
`28`	`28`
`29`	`29`	`void Select::executeImpl(Message msg) {`
`30`		`- if (matches(msg)) {`
	`30`	`+ //pass through action for everything that is not a field, e.g. Flush`
	`31`	`+ if (matches(msg) \|\| (msg.tag() != message::Message::Tag::Field)) {`
`31`	`32`	`executeNext(std::move(msg));`
`32`	`33`	`}`
`33`	`34`	`}`