This would allow accumulate to update its state when a new value of `state_stream` came down, allowing us to reset the accumulate state as needed.
This would allow accumulate to update its state when a new value of
state_streamcame down, allowing us to reset the accumulate state as needed.