Ignoring semantics, is it safe to do the following...
# rx
n
Ignoring semantics, is it safe to do the following?
Copy code
fun foo(bar: Observable<Int>) : Observable<Int> {
  Observable.create { emitter ->
    emitter.setDisposable(
       bar.subscribe { emitter.onNext(it) }
    )
  }
}