Use the StreamExt.onErrorResumeNext function to concatenate events from two source treams after the first stream errors or finishes.