code: func (c *MockProducer) Register() <-chan interface{} {
  	c.Lock()
  	defer c.Unlock()
  
  	eventch := make(chan interface{})
  	c.eventChannels = append(c.eventChannels, eventch)
  	return eventch
  }
docs: // Register registers an event channel