robin
fun <T> bindToLifecycle(): Observable.Transformer<T, T> { return { source -> source.takeUntil { ... }} }