code: func (c *MockConnection) Close() {
  	if !atomic.CompareAndSwapInt32(&c.closed, 0, 1) {
  		// Already closed
  		return
  	}
  
  	c.producer.Close()
  	close(c.rcvch)
  }
docs: // Close implements the MockConnection interface