implementing takeUntil with groupSimultaneous, discover problem with synchronous sources