### Question:
DefaultBlockingIterableProcessor implements Processor<T> { @Override public BlockingIterator<T> iterator() { return new PollingBlockingIterator<>(buffer); } DefaultBlockingIterableProcessor(final BlockingProcessorSignalsHolder<T> buffer); @Override BlockingIterator<T> iterator(); @Override void next(@Nullable final T nextItem); @Override void fail(final Throwable cause); @Override void close();  }### Answer:
@Test public void hasNextTimesout() throws TimeoutException { BlockingIterator<Integer> iterator = processor.iterator(); expectedException.expect(instanceOf(TimeoutException.class)); iterator.hasNext(1, TimeUnit.SECONDS); }