From 79f06c7daf2b7b028179ec1081ea22f3ade83b66 Mon Sep 17 00:00:00 2001 From: Nils Homer Date: Mon, 27 Dec 2021 09:17:40 -0700 Subject: [PATCH] Update AsyncIterator.scala --- .../com/fulcrumgenomics/commons/async/AsyncIterator.scala | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/main/scala/com/fulcrumgenomics/commons/async/AsyncIterator.scala b/src/main/scala/com/fulcrumgenomics/commons/async/AsyncIterator.scala index 9780c88..5219de9 100644 --- a/src/main/scala/com/fulcrumgenomics/commons/async/AsyncIterator.scala +++ b/src/main/scala/com/fulcrumgenomics/commons/async/AsyncIterator.scala @@ -66,7 +66,7 @@ class AsyncIterator[T](private val source: Iterator[T], bufferSize: Option[Int] // Get the next item, or wait until the underlying thread is done and there are no more items in the queue while (buffer.isEmpty && !(this.done && this.queue.isEmpty)) { - checkAndRaise() // check if hte underlying thread raised an exception + checkAndRaise() // check if the underlying thread raised an exception tryAndModifyInterruptedException("Interrupted waiting on taking from the queue.") { buffer = Option(this.queue.poll(50, TimeUnit.MILLISECONDS)) } @@ -96,4 +96,4 @@ class AsyncIterator[T](private val source: Iterator[T], bufferSize: Option[Int] item } } -} \ No newline at end of file +}