We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 7c11a93 commit f691457Copy full SHA for f691457
phlex/core/declared_unfold.hpp
@@ -171,6 +171,10 @@ namespace phlex::experimental {
171
auto child = g.make_child_for(counter++, std::move(new_products));
172
message const child_msg{child, eom->make_child(child->id()), ++msg_counter_};
173
output_port<0>(unfold_).try_put(child_msg);
174
+
175
+ // Every data cell needs a flush (for now)
176
+ message const child_flush_msg{child->make_flush(), nullptr, ++msg_counter_};
177
+ output_port<0>(unfold_).try_put(child_flush_msg);
178
}
179
180
0 commit comments