// how to use

SafeZip.zip(single1, single2, ::merge).subscribe(...)