Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
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
121
func
(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
TestCorrectStreamWakeup
Function · 0.80
Calls
2
Lock
Method · 0.80
Unlock
Method · 0.80
Tested by
1
TestCorrectStreamWakeup
Function · 0.64