@check_input_stream_count(1)
    def _execute(self, sources, alignment_stream, interval):
        for (time, _) in sources[0].window(interval, force_calculation=True):
            yield StreamInstance(
                time, TimeInterval(time + self._lower, time + self._upper))