Gabe Kauffman
val publishSubject = PublishSubject.create<Double>().toSerialized().observeOn(Schedulers.computation())