public final TestSubscriber<T> await(){
  if (cdl.getCount() == 0) {
    return this;
  }
  try {
    cdl.await();
  }
 catch (  InterruptedException ex) {
    throw new AssertionError("Wait interrupted",ex);
  }
  return this;
}

public final TestSubscriber < T > await ( ) { if ( cdl . getCount ( ) == 0 ) { return this ; } try { cdl . await ( ) ; } catch ( InterruptedException ex ) { throw new AssertionError ( "Wait interrupted" , ex ) ; } return this ; }
blocking method that waits until a complete successfully or error signal is received .
