question: public final AssertSubscriber < T > assertTerminated ( ) { if ( cdl . getCount ( ) != 0 ) { throw new AssertionError ( "Not terminated" , null ) ; } return this ; }
target:  Assert either complete successfully or error signal has been received.