merge(o1, o2).take(1)
# rx
u
merge(o1, o2).take(1)