readTable method

Implementation

ArrowTable readTable() => _guard(() {
  final messages = _MessageCursor(bytes, 0, limits);
  final first = messages.next();
  if (first == null || first.headerType != _headerSchema) {
    throw const FormatException(
      'IPC stream must begin with a Schema message',
    );
  }
  final state = _ReadState(_decodeSchema(first.header, limits), limits);
  for (var m = messages.next(); m != null; m = messages.next()) {
    state.accept(m, allowReplacement: true);
  }
  return state.table();
});