readMessageBegin method

  1. @override
TMessage readMessageBegin()
override

read

Implementation

@override
TMessage readMessageBegin() {
  String name;
  int type;
  int seqid;

  int size = readI32();
  if (size < 0) {
    int version = size & VERSION_MASK;
    if (version != VERSION_1) {
      throw TProtocolError(TProtocolErrorType.BAD_VERSION,
          "Bad version in readMessageBegin: $version");
    }
    type = size & 0x000000ff;
    name = readString();
    seqid = readI32();
  } else {
    if (strictRead) {
      throw TProtocolError(TProtocolErrorType.BAD_VERSION,
          "Missing version in readMessageBegin");
    }
    name = _readString(size);
    type = readByte();
    seqid = readI32();
  }
  return TMessage(name, type, seqid);
}