This could be interpreted as “Subscriber.onNext does not need to be thread-safe”. Is this the intention?