publish merge take1, skip1.flatmap diff.observero...
# rx
u
publish merge take1, skip1.flatmap diff.observeron mainthread?