tuned signature;
authorwenzelm
Tue, 07 Sep 2021 15:05:57 +0200
changeset 74252 3300847d75ae
parent 74251 e6f1990c4d34
child 74253 45dc9de1bd33
tuned signature;
src/Pure/Concurrent/consumer_thread.scala
--- a/src/Pure/Concurrent/consumer_thread.scala	Tue Sep 07 15:02:53 2021 +0200
+++ b/src/Pure/Concurrent/consumer_thread.scala	Tue Sep 07 15:05:57 2021 +0200
@@ -66,7 +66,7 @@
     val ack: Option[Synchronized[Option[Exn.Result[Unit]]]] =
       if (acknowledge) Some(Synchronized(None)) else None
 
-    def await: Unit =
+    def await(): Unit =
     {
       for (a <- ack) {
         Exn.release(a.guarded_access({ case None => None case res => Some((res.get, res)) }))
@@ -80,7 +80,7 @@
       if (is_active) mailbox.send(Some(req))
       else error("Consumer thread not active: " + quote(thread.getName))
     }
-    req.await
+    req.await()
   }
 
   @tailrec private def main_loop(msgs: List[Option[Request]]): Unit =