|
@@ -48,6 +48,7 @@ public abstract class EntityIterator implements Iterator<Identifiable> { |
|
|
try { |
|
|
try { |
|
|
return queue.take(); |
|
|
return queue.take(); |
|
|
} catch (InterruptedException e) { |
|
|
} catch (InterruptedException e) { |
|
|
|
|
|
error.set(e); |
|
|
return die("next: queue.take interrupted"); |
|
|
return die("next: queue.take interrupted"); |
|
|
} |
|
|
} |
|
|
} |
|
|
} |
|
|