inspect

fun inspect(callback: (value: T) -> Unit): Observable<T>(source)