question: reset this observer to the give cluster state . any pending waits will be canceled . concode_field_sep boolean timedOut concode_elem_sep ChangePredicate changePredicate concode_elem_sep ChangePredicate MATCH_ALL_CHANGES_PREDICATE concode_elem_sep ESLogger logger concode_elem_sep Long startTimeNS concode_elem_sep Listener listener concode_elem_sep AtomicReference<ObservingContext> observingContext concode_elem_sep TimeoutClusterStateListener clusterStateListener concode_elem_sep TimeValue timeOutValue concode_elem_sep AtomicReference<ObservedState> lastObservedState concode_elem_sep ClusterService clusterService concode_elem_sep ClusterState clusterState concode_elem_sep ClusterState.ClusterStateStatus status concode_field_sep void waitForNextChange concode_elem_sep void waitForNextChange concode_elem_sep void waitForNextChange concode_elem_sep void waitForNextChange concode_elem_sep void onClose concode_elem_sep void clusterChanged concode_elem_sep void postAdded concode_elem_sep boolean apply concode_elem_sep boolean apply concode_elem_sep boolean apply concode_elem_sep boolean apply concode_elem_sep boolean apply concode_elem_sep boolean apply concode_elem_sep ClusterState observedState concode_elem_sep void onNewClusterState concode_elem_sep void onTimeout concode_elem_sep void onTimeout concode_elem_sep String toString concode_elem_sep boolean isTimedOut concode_elem_sep void onClusterServiceClose concode_elem_sep boolean validate
target: void function ( ClusterState arg0 ) { if ( observingContext . getAndSet ( null ) != null ) { clusterService . remove ( clusterStateListener ) ; } lastObservedState . set ( new ObservedState ( arg0 ) ) ; }