Gabe Kauffman
publishSubject.observeOn(Schedulers.computation()).onNext(AudioProcessingHelper.calculateAudioVolume(audioSample))