import rx from rx import operators as ops s1 = rx.from_(['A', 'B', 'C', 'D', 'E', 'F']) s2 = rx.range(1,7) stream = rx.zip(s1, s2) stream.subscribe(lambda s: print(s[0], s[1]))