Gabe Kauffman
11/18/2020, 11:44 PMSchedulers.computation()
. But, I can't figure out where to put the observeOn()
here
val publishSubject = PublishSubject.create<Double>().toSerialized()
remoteAudioTrackPublication.audioTrack?.addSink(object : AudioSink {
override fun renderSample(
audioSample: ByteBuffer,
encoding: Int,
sampleRate: Int,
channels: Int
) {
publishSubject.onNext(AudioProcessingHelper.calculateAudioVolume(audioSample))
}
})