Dynamically add upstreams to zip

[mrtj]

Hello, is it possible to dynamically ad upstreams to zip once it was created? Ideally, I am looking for something like this:

from streamz import Stream

src1 = Stream()
src2 = Stream()

zp = Stream.zip(src1, src2)
zp.sink(print)

src1.emit(1)
src2.emit(2)
# (1, 2)

src3 = Stream()
zp.add_upstream(src3) # <-- ???

src1.emit(1)
src2.emit(2)
src3.emit(3)

# (1, 2, 3)

[martindurant]

What you want is:

src3.connect(zp)

[mrtj]

This rocks, thank you!