void function ( Object arg0 ) { Assert . assertTrue ( countDownLatch . await ( 1L , TimeUnit . SECONDS ) ) ; try { Assert . assertEquals ( arg0 , future . get ( ) ) ; } catch ( ExecutionException loc0 ) { throw loc0 . getCause ( ) ; } }
verify that the listener completes in a reasonable amount of time , and asserts that the future returns the expected data . concode_field_sep ListenableFuture<?> future concode_elem_sep CountDownLatch countDownLatch concode_field_sep void assertTimeout concode_elem_sep void run concode_elem_sep void assertException