MCPcopy Create free account
hub / github.com/daodst/chat / ch

Method ch

syncapi/notifier/userstream.go:121–125  ·  view source on GitHub ↗
()

Source from the content-addressed store, hash-verified

119}
120
121func (s *UserDeviceStream) ch() <-chan struct{} {
122 s.lock.Lock()
123 defer s.lock.Unlock()
124 return s.signalChannel
125}
126
127// GetSyncPosition returns last sync position which the UserStream was
128// notified about

Callers 1

TestCorrectStreamWakeupFunction · 0.80

Calls 2

LockMethod · 0.80
UnlockMethod · 0.80

Tested by 1

TestCorrectStreamWakeupFunction · 0.64