Continuous Stream Processing with Event Regeneration

Here's another tricky stream problem. I have an effect which yields a stream of events. I need an effect that generates that stream and emits each event to a consumer as they occur, but at the end of the stream may process the emitted events, and re-generate the stream. But the consumer should see this only as a single stream.