diff --git a/syncapi/notifier/userstream.go b/syncapi/notifier/userstream.go index 720185d52..07be328e0 100644 --- a/syncapi/notifier/userstream.go +++ b/syncapi/notifier/userstream.go @@ -89,10 +89,9 @@ func (s *UserDeviceStream) Broadcast(pos types.StreamingToken) { s.lock.Lock() defer s.lock.Unlock() - s.pos = pos + s.pos.ApplyUpdates(pos) close(s.signalChannel) - s.signalChannel = make(chan struct{}) }