mirror of
https://github.com/matrix-org/dendrite.git
synced 2025-12-23 06:43:09 -06:00
Fix ordering hopefully
This commit is contained in:
parent
2b653f5edf
commit
3f3b4a3c08
|
|
@ -137,8 +137,8 @@ func (r *Inputer) InputRoomEvents(
|
|||
}
|
||||
|
||||
// Send the task to the worker.
|
||||
go func(task *inputTask) { worker.input <- task }(tasks[i])
|
||||
go worker.start()
|
||||
worker.input <- tasks[i]
|
||||
}
|
||||
|
||||
// Wait for all of the workers to return results about our tasks.
|
||||
|
|
|
|||
Loading…
Reference in a new issue