observable

fun <T : Any> observable(block: (ObservableEmitter<T>) -> Unit): Observable<T>