cedric
12/01/2015, 9:16 PMfun <T> bindToLifecycle() : rx.Observable.Transformer<T, T> = rx.Observable.Transformer({})
fun f() {
val b = bindToLifecycle<Long>()
rx.Observable.interval(1, TimeUnit.SECONDS)
.doOnUnsubscribe {println("Unsubscribing subscription from onStart()") }
.compose(b)
.subscribe { num -> println("Started in onStart(), running until in onStop(): " + num) }
}