timeout operator is not re-emiting source

[gnzsnz]

Operator timeout is not re-emiting source emits

    def on_source(self, *args):
        loop = get_event_loop()
        self._last_time = loop.time()
        # no emit from source

example

e = await ev.Event.sequence([1,2,3,4],interval=0.2).timeout(1).list()
# expected e == [1,2,3,4]
assert e != [1,2,3,4]
# actual
assert e == []

fix

    def on_source(self, *args):
        loop = get_event_loop()
        self._last_time = loop.time()
        Op.on_source(self, *args)

with this fix, we can pipe operators

e = await ev.Event.sequence([1,2,3,4],interval=0.2).timeout(1).list()
assert e == [1,2,3,4]

[gnzsnz]

oh boy

I really messed up, i committed to main. I'll roll-back and push a pull-request. give me a couple of days...

[mattsta]

Cool find and fix! I'll get these recent updates together soon for a new checkpoint update.