code: func (t *MockSocket) Close() error {
  	select {
  	case <-t.closed:
  		// Do nothing
  	default:
  		close(t.closed)
  		close(t.expectedRequests)
  		close(t.receivedMessages)
  	}
  	return nil
  }
docs: // Close implements the Socket interface