TimelyDataflow / timely-dataflow

A modular implementation of timely dataflow in Rust
MIT License
3.25k stars 272 forks source link

give_container: Only push if message non-empty #524

Closed antiguru closed 1 year ago

antiguru commented 1 year ago

This fixes #523. The reason for the error is that guarded messages are only emitted when the message is non-empty. In this case however, the message was empty, recording that a message was sent, but never recording that the message was received. The fix makes sure to only send within give_container when the message is non-empty. This solves this particular problem, but the requirements around empty messages are still somewhat implicit.