@org.junit.After public void executeTest() throws Throwable {
  try {
    testEnv.executeTest();
  }
 catch (  AssertionError assertionError) {
    if (testEnv.hasBeenStopped()) {
      throw new AssertionError("Test terminated due timeout!" + assertionError.getMessage());
    }
    throw assertionError;
  }
}

@ org . junit . After public void executeTest ( ) throws Throwable { try { testEnv . executeTest ( ) ; } catch ( AssertionError assertionError ) { if ( testEnv . hasBeenStopped ( ) ) { throw new AssertionError ( "Test terminated due timeout!" + assertionError . getMessage ( ) ) ; } throw assertionError ; } }
executes the test and verifies the output received by the sinks .
