mirror of
https://github.com/hoernschen/dendrite.git
synced 2024-12-27 23:48:27 +00:00
Don't block on RS input API
This commit is contained in:
parent
71eebd6bc3
commit
efb9588a36
1 changed files with 13 additions and 11 deletions
|
@ -166,6 +166,7 @@ func (r *Inputer) InputRoomEvents(
|
|||
worker.input.push(tasks[i])
|
||||
}
|
||||
|
||||
/*
|
||||
// Wait for all of the workers to return results about our tasks.
|
||||
wg.Wait()
|
||||
|
||||
|
@ -179,4 +180,5 @@ func (r *Inputer) InputRoomEvents(
|
|||
return
|
||||
}
|
||||
}
|
||||
*/
|
||||
}
|
||||
|
|
Loading…
Reference in a new issue