Rx: zip-подобный оператор, который продолжается после завершения одного из потоков?

Я ищу, чтобы объединить потоки (наблюдаемые), которые начинаются и заканчиваются асинхронно: