public final TestSubscriber<T> assertTerminated(){
  if (cdl.getCount() != 0) {
    throw new AssertionError("Not terminated",null);
  }
  return this;
}

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