unsafeRunAndForget => unsafeRunSync for enqueueByteBuffer

fmonniot · Jul 12, 2022 · 0b01a80 · 0b01a80
1 parent f85910c
commit 0b01a80
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/src/main/scala/eu/monniot/process/Process.scala b/src/main/scala/eu/monniot/process/Process.scala
@@ -111,7 +111,7 @@ object Process {
  // Ensure we consume the entire buffer in case it's not used.
  buffer.position(buffer.limit)
 
- dispatcher.unsafeRunAndForget(q.offer(Some(bv)))
+ dispatcher.unsafeRunSync(q.offer(Some(bv)))
  }
 
  override def onStdout(buffer: ByteBuffer, closed: Boolean): Unit =