You can't do `publishSubject.observeOn(Schedulers....
# rx
g
You can't do
publishSubject.observeOn(Schedulers.computation()).onNext(AudioProcessingHelper.calculateAudioVolume(audioSample))