src/Pure/Build/database_progress.scala
changeset 79884 caf61c098754
parent 79873 6c19c29ddcbe
child 79887 17220dc05991
equal deleted inserted replaced
79883:6fa259b24deb 79884:caf61c098754
   247       }
   247       }
   248       else Nil
   248       else Nil
   249     }
   249     }
   250 
   250 
   251     _consumer = Consumer_Thread.fork_bulk[Progress.Output](name = "Database_Progress.consumer")(
   251     _consumer = Consumer_Thread.fork_bulk[Progress.Output](name = "Database_Progress.consumer")(
   252       bulk = _ => true, timeout = timeout,
   252       bulk = _ => true,
       
   253       timeout = timeout,
   253       consume = { bulk_output =>
   254       consume = { bulk_output =>
   254         val results =
   255         val results =
   255           if (bulk_output.isEmpty) consume(Nil)
   256           if (bulk_output.isEmpty) consume(Nil)
   256           else bulk_output.grouped(200).toList.flatMap(consume)
   257           else bulk_output.grouped(200).toList.flatMap(consume)
   257         (results, true) })
   258         (results, true) })