// Subscribe allows a client to receive published activities.
Subscribe allows a client to receive published activities.
// Subscribe allows a client to receive published activities .
func (h *handler) Subscribe() <-chan *vocab.ActivityType {
	ch := make(chan *vocab.ActivityType, h.BufferSize)
	h.mutex.Lock()
	h.subscribers = append(h.subscribers, ch)
	h.mutex.Unlock()
	return ch
}
func ( h * handler ) Subscribe ( ) <- chan * vocab . ActivityType { ch := make ( chan * vocab . ActivityType , h . BufferSize ) h . mutex . Lock ( ) h . subscribers = append ( h . subscribers , ch ) h . mutex . Unlock ( ) return ch }
Subscribe allows a client to receive published activities.
Subscribe allows a client to receive published activities .