code: func (c *MockConnection) Receive(eventch chan<- interface{}) {
  	for {
  		select {
  		case e, ok := <-c.producerch:
  			if !ok {
  				return
  			}
  			eventch <- e
  		case e, ok := <-c.rcvch:
  			if !ok {
  				return
  			}
  			eventch <- e
  		}
  	}
  }
docs: // Receive implements the MockConnection interface