Stream<List<int>> s = ...;

s.transform(const Utf8Decoder())
  .transform(const JsonEventDecoder())
  .flatten();

await for (JsonEvent je in s) {
  print("Event Type: ${je.type.name} Value: ${je.value}");
}

Stream<String> s = Stream.value(...);

s.transform(const JsonEventDecoder())
  .flatten();

await for (JsonEvent je in s) {
  print("Event Type: ${je.type.name} Value: ${je.value}");
}

class MyClass with JsonObjectTraverser {
  late int x;
  late List<MyClass> arr;
  late List<int> pArr;
  late List<List<int>> pNestedArray;
  String? text;

  @override
  Future<void> readJson(String key) async {
    switch (key) {
      case "x":
        x = await this.readPropertyJsonContinue<int>();
        break;
      case "text":
        y = await this.readPropertyJsonContinue<String?>();
        break;
      case "arr":
        arr = await this.readPropertyJsonContinue<MyClass>(creator: MyClass.new);
        break;
      case "pArr":
        pArr = await this.readArrayJsonContinue<int>().toList();
        break;
      case "pNestedArray":
        pNestedArray = await this.readNestedArrayJsonContinue<int>().toList();
        break;
    }
  }
}

MyClass mc = MyClass();
await mc.loadJson(streamIterator);

class MyArrayClass with JsonArrayTraverser<MyClass> {
  @override
  FutureOr<MyClass> Function()? creator = MyClass.new; // or in constructor

  MyArrayClass() : super([]) {
    // creator = MyClass.new;
  }
}

MyArrayClass mc = MyArrayClass();
await mc.loadJsonFromStream(stream);