dispatches a notificationlite value to the actual observer . concode_field_sep Action1<SubjectObserver<T>> onTerminated concode_elem_sep Observer<? super T> actual concode_elem_sep boolean emitting concode_elem_sep boolean caughtUp concode_elem_sep NotificationLite<T> nl concode_elem_sep SubjectObserver[] NO_OBSERVERS concode_elem_sep Object index concode_elem_sep boolean first concode_elem_sep boolean active concode_elem_sep AtomicReferenceFieldUpdater<SubjectSubscriptionManager,State> STATE_UPDATER concode_elem_sep Action1<SubjectObserver<T>> onAdded concode_elem_sep State EMPTY concode_elem_sep boolean fastPath concode_elem_sep State<T> state concode_elem_sep State TERMINATED concode_elem_sep Action1<SubjectObserver<T>> onStart concode_elem_sep boolean terminated concode_elem_sep SubjectObserver[] observers concode_elem_sep List<Object> queue concode_elem_sep Object latest concode_field_sep boolean add concode_elem_sep State add concode_elem_sep SubjectObserver<T>[] next concode_elem_sep Observer<? super T> getActual concode_elem_sep void addUnsubscriber concode_elem_sep void set concode_elem_sep void onError concode_elem_sep void emitLoop concode_elem_sep void onCompleted concode_elem_sep I index concode_elem_sep void index concode_elem_sep void remove concode_elem_sep State remove concode_elem_sep void onNext concode_elem_sep void call concode_elem_sep void emitFirst concode_elem_sep void emitNext concode_elem_sep Object get concode_elem_sep SubjectObserver<T>[] terminate concode_elem_sep SubjectObserver<T>[] observers
void function ( Object arg0 , final NotificationLite < T > arg1 ) { if ( arg0 != null ) { arg1 . accept ( actual , arg0 ) ; } }