mirrors/dendrite
1
0
Fork 0
mirror of https://github.com/matrix-org/dendrite.git synced 2025-12-19 21:03:09 -06:00
Code Issues Packages Projects Releases Wiki Activity

Tweaks

Browse source
This commit is contained in:
Neil Alexander 2020-05-27 16:05:14 +01:00
parent 792e04d69d
commit 06cbe32545
1 changed files with 1 additions and 1 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
syncapi/sync/notifier.go
View file

@ -175,7 +175,7 @@ func (n *Notifier) setUsersJoinedToRooms(roomIDToUserIDs map[string][]string) {
func (n *Notifier) wakeupUsers(userIDs []string, newPos types.StreamingToken) {
for _, userID := range userIDs {
for deviceID, stream := range n.fetchUserStreams(userID) {
for _, stream := range n.fetchUserStreams(userID) {
if stream != nil {
stream.Broadcast(newPos) // wake up all goroutines Wait()ing on this stream
}