Process expired events through streams

[agentultra]

This depends on #6

The reaping process should set the event's state to "expired" and pass them through the streams channel.