added curses sketch example, scan operator, take until 1st observable on_next, fixed distinct changes bug