code: func (t *MockSocket) ReadMessage() (int, []byte, error) {
  	message, isOpen := <-t.receivedMessages
  	if !isOpen {
  		return 0, nil, errors.New("socket closed by test case")
  	}
  	return 1, message, nil
  }
docs: // ReadMessage implements the Socket interface