added again combine and takeUntil using forkIO + Tests