refactor rest of one source streams
refactor .throttle() and .delay()