reactivex_observable_from_list_with_map_filter_subscribe.py

1import reactivex
2from reactivex import operators as ops
3
4source = reactivex.of("Alpha", "Beta", "Gamma", "Delta", "Epsilon")
5
6composed = source.pipe(
7    ops.map(lambda s: len(s)),
8    ops.filter(lambda i: i >= 5)
9)
10
11composed.subscribe(
12    on_next=lambda i: print("Received: {0}".format(i)),
13    on_error=lambda e: print("Error Occurred: {0}".format(e)),
14    on_completed=lambda: print("Done!"),
15)