Implement a simple reactive observable with map, filter, and subscribe.