waits a fixed timeout for the stream to terminate . concode_field_sep SettableFuture<T> firstValue concode_elem_sep CountDownLatch latch concode_elem_sep Throwable error concode_elem_sep List<T> results concode_field_sep Throwable getError concode_elem_sep void onError concode_elem_sep ListenableFuture<T> firstValue concode_elem_sep List<T> getValues concode_elem_sep void onCompleted concode_elem_sep StreamRecorder<T> create concode_elem_sep void onNext
boolean function ( int arg0 , TimeUnit arg1 ) { return latch . await ( arg0 , arg1 ) ; }