fromJsonStream method

Stream<T> fromJsonStream(
  1. Stream<List<int>> json
)

Implementation

Stream<T> fromJsonStream(Stream<List<int>> json) {
  final controller = StreamController<T>();
  _fromJsonStream(json) //
      .then(controller.addStream)
      .catchError(controller.addError)
      .whenComplete(controller.close);
  return controller.stream;
}