parseAsync method

Implementation

@override
AsyncResult<int> parseAsync(State<ChunkedData<StringReader>> state) {
  final result = AsyncResult<int>();
  if (!backtrack(state)) {
    result.ok = false;
    return result;
  }

  final input = state.input;
  input.buffering++;
  void parse() {
    final end = input.end;
    if (state.pos >= end && !input.isClosed) {
      input.sleep = true;
      input.handler = parse;
      return;
    }

    final data = input.data;
    input.buffering--;
    if (state.pos < end) {
      final source = data.source;
      final c = source.runeAt(state.pos - input.start);
      state.pos += c > 0xffff ? 2 : 1;
      result.value = Result(c);
      result.ok = true;
      input.handler = result.handler;
      return;
    }

    result.ok = false;
    state.fail<Object?>(const ErrorUnexpectedEndOfInput());
    input.handler = result.handler;
  }

  parse();
  return result;
}