nhaarman
fun foo(bar: Observable<Int>) : Observable<Int> { Observable.create { emitter -> emitter.setDisposable( bar.subscribe { emitter.onNext(it) } ) } }