question: public void reset ( ClusterState toState ) { if ( observingContext . getAndSet ( null ) != null ) { clusterService . remove ( clusterStateListener ) ; } lastObservedState . set ( new ObservedState ( toState ) ) ; }
target:  reset this observer to the give cluster state. Any pending waits will be canceled.