if err != nil {
		return nil, err
	}

	_, _, err = z.u.WriteMsgUnix(data, rights, nil)
	if err != nil {
		return nil, err
	}

	// wait for ack
	return z.readMessage(readWriteDeadline)
}

func (z *ZtunnelConnection) readMessage(timeout time.Duration) (*zdsapi.WorkloadResponse, error) {
	m, _, err := readProto[zdsapi.WorkloadResponse](z.u, timeout, nil)
	return m, err
}

  private fun readMessageFrame() {
    val opcode = this.opcode
    if (opcode != OPCODE_TEXT && opcode != OPCODE_BINARY) {
      throw ProtocolException("Unknown opcode: ${opcode.toHexString()}")
    }

    readMessage()

    if (readingCompressedMessage) {
      val messageInflater =
        this.messageInflater
          ?: MessageInflater(noContextTakeover).also { this.messageInflater = it }

pkg net/http/pprof, func Index(http.ResponseWriter, *http.Request)
pkg net/http/pprof, func Profile(http.ResponseWriter, *http.Request)
pkg net/http/pprof, func Symbol(http.ResponseWriter, *http.Request)
pkg net/mail, func ReadMessage(io.Reader) (*Message, error)
pkg net/mail, method (*Address) String() string
pkg net/mail, method (Header) AddressList(string) ([]*Address, error)
pkg net/mail, method (Header) Date() (time.Time, error)