parseAsync method

  1. @override
AsyncResult<List<O1>> parseAsync(
  1. State<ChunkedData<I>> state
)
override

Experimental. Not yet fully implemented

Implementation

@override
AsyncResult<List<O1>> parseAsync(State<ChunkedData<I>> state) {
  final result = AsyncResult<List<O1>>();
  late AsyncResult<O1> r1;
  late AsyncResult<O2> r2;
  final list = <O1>[];
  var action = 0;
  void parse() {
    while (true) {
      switch (action) {
        case 0:
          r1 = p.parseAsync(state);
          action = 1;
          if (r1.ok == null) {
            r1.handler = parse;
            return;
          }

          break;
        case 1:
          final r = r1.value;
          if (r == null) {
            result.value = Result(list);
            result.ok = true;
            state.input.handler = result.handler;
            action = -1;
            return;
          }

          list.add(r.value);
          action = 2;
          break;
        case 2:
          r2 = sep.parseAsync(state);
          action = 3;
          if (r2.ok == null) {
            r2.handler = parse;
            return;
          }

          break;
        case 3:
          final r = r2.value;
          if (r == null) {
            result.value = Result(list);
            result.ok = true;
            state.input.handler = result.handler;
            action = -1;
            return;
          }

          action = 4;
          break;
        case 4:
          r1 = p.parseAsync(state);
          action = 5;
          if (r1.ok == null) {
            r1.handler = parse;
            return;
          }

          break;
        case 5:
          final r = r1.value;
          if (r == null) {
            result.ok = false;
            state.input.handler = result.handler;
            action = -1;
            return;
          }

          list.add(r.value);
          action = 2;
          break;
        default:
          throw StateError('Invalid state: $action');
      }
    }
  }

  parse();
  return result;
}