I want to find a match in another stream and combine it with current item. numbers = [1, 2, 3, 4, 5] numbers_in_char = ["1", "2", "3", "4", "5"] textnumbers_in_stream = rx.defer(rx.from_iterable(numbers_in_char)) def exists_in_words(number, words): words.pipe( op.filter(lambda w: int(w) == number), op.map(lambda w: (number, w)) ) rx \ .from_iterable(numbers) \ .pipe(op.map(lambda number: exists_in_words(number, textnumbers_in_stream))) \… Read More Filtering another stream based on item in current stream using rxpy