Transform *args: Union[Iterable[Observable], Observable] to *args: Observable for operators : amb catch: retry operator relies on iterator as 1st arg combine_latest concat: repeat, for_in, while_do operators rely on iterator as 1st arg merge on_error_resume_next with_latest_from zip