MCPcopy
hub / github.com/coder/websocket / addSubscriber

Method addSubscriber

internal/examples/chat/chat.go:179–183  ·  view source on GitHub ↗

addSubscriber registers a subscriber.

(s *subscriber)

Source from the content-addressed store, hash-verified

177
178// addSubscriber registers a subscriber.
179func (cs *chatServer) addSubscriber(s *subscriber) {
180 cs.subscribersMu.Lock()
181 cs.subscribers[s] = struct{}{}
182 cs.subscribersMu.Unlock()
183}
184
185// deleteSubscriber deletes the given subscriber.
186func (cs *chatServer) deleteSubscriber(s *subscriber) {

Callers 1

subscribeMethod · 0.95

Calls 1

LockMethod · 0.45

Tested by

no test coverage detected