# HG changeset patch
# User wenzelm
# Date 1631019957 -7200
# Node ID 3300847d75ae04fc245cd122ddccd8d055ff4024
# Parent  e6f1990c4d34595c4ae169d80f311999e6f969b5
tuned signature;

diff -r e6f1990c4d34 -r 3300847d75ae 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 =