@@ -195,10 +195,11 @@ public Future<V> poll() { return completionQueue.poll(); } - public Future<V> poll(long timeout, TimeUnit unit) throws InterruptedException { + public Future<V> poll(long timeout, TimeUnit unit) + throws InterruptedException { return completionQueue.poll(timeout, unit); } }