Observable < T > function ( Activity arg0 , Observable < T > arg1 ) { Assertions . assertUiThread ( ) ; return arg1 . observeOn ( mainThread ( ) ) . lift ( new OperatorConditionalBinding < T , Activity > ( arg0 , ACTIVITY_VALIDATOR ) ) ; }
binds the given source sequence to an activity . this helper will schedule the given sequence to be observed on the main ui thread and ensure that no notifications will be forwarded to the activity in case it is scheduled to finish . you should unsubscribe from the returned observable in ondestroy at the latest , in order to not leak the activity or an inner subscriber . conversely , when the source sequence can outlive the activity , make sure to bind to new instances of the activity again , e.g. after going through configuration changes . refer to the samples project for actual examples . concode_field_sep Func1<Fragment,Boolean> FRAGMENT_VALIDATOR concode_elem_sep Func1<android.support.v4.app.Fragment,Boolean> FRAGMENTV4_VALIDATOR concode_elem_sep Func1<Activity,Boolean> ACTIVITY_VALIDATOR concode_field_sep Boolean call concode_elem_sep Boolean call concode_elem_sep Boolean call concode_elem_sep Observable<T> bindSupportFragment concode_elem_sep Observable<T> bindFragment