Why does this need to be synchronized? We have a single Observable sequence that will not interleave `onNext` calls (by contract) so I don't think we need this here.