replace await sleep/timeout pipelines with Rx #kornwolf