equal
deleted
inserted
replaced
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) }) |