readFrame method

Future readFrame()

Implementation

Future readFrame() async {
  transport_.readAll(i32buf, 0, 4);
  int size = decodeWord(i32buf, 0);

  if (size < 0) {
    throw TTransportError(TTransportErrorType.NEGATIVE_SIZE,
        "Read a negative frame size $size");
  }

  if (size > maxLength_) {
    throw TTransportError(TTransportErrorType.UNKNOWN,
        "Frame size $size larger than max length $maxLength_");
  }

  final Int8List buff = Int8List(size);
  transport_.readAll(buff, 0, size);
  readBuffer_?.reset(buf: buff);
}