Поток и будущее в дротике - PullRequest
Новая
       19

Поток и будущее в дротике

1 голос
/ 21 апреля 2019

Я уже некоторое время без проблем использую базовую асинхронность / ожидание, и мне показалось, что я понимаю, как она работает.Не могу сказать, что я эксперт в этом, но я понял суть этого.Я просто не могу понять Потоки, хотяДо сегодняшнего дня я думал, что понимаю, как они работают (в основном, в стиле Reactive Programming), но я не могу заставить их работать в Dart.

Я работаю над уровнем персистентности с возможностью сохранения и извлечения (JSON) файлы.Я использовал пример fileManager в качестве ориентира. 

import 'dart:io';
import 'dart:async';
import 'package:intl/intl.dart'; //date
import 'package:markdowneditor/model/note.dart';//Model
import 'package:path_provider/path_provider.dart';
import 'package:path/path.dart' as p;
import 'package:flutter/foundation.dart'; //log
import 'package:simple_permissions/simple_permissions.dart';//OS permissions

class FileManager {
  static final FileManager _singleton = new FileManager._internal();

  factory FileManager() {
    return _singleton;
  }

  FileManager._internal();

  Future<String> get _localPath async {
    final directory = (await getApplicationDocumentsDirectory()).toString();
    return p.join(directory, "notes"); //path takes strings and not Path objects
  }

  Future<File> writeNote(Note note) async {
    var file = await _localPath;
    file = p.join(
        file,
        DateFormat('kk:mm:ssEEEMMd').format(DateTime.now()) +
            " " +
            note.title); //add timestamp to title
    // Write the file

    SimplePermissions.requestPermission(Permission.WriteExternalStorage)
        .then((value) {
      if (value == PermissionStatus.authorized) {
        return File(file).writeAsString('$note');
      } else {
        SimplePermissions.openSettings();
        return null;
      }
    });

  }

  Future<List<Note>> getNotes() async {
    //need file access permission on android. use https://pub.dartlang.org/packages/simple_permissions#-example-tab-
    final file = await _localPath;

    SimplePermissions.requestPermission(Permission.ReadExternalStorage)
        .then((value) {
      if (value == PermissionStatus.authorized) {
        try {
          Stream<FileSystemEntity> fileList =
              Directory(file).list(recursive: false, followLinks: false);

          // await for(FileSystemEntity s in fileList) { print(s); }
          List<Note> array = [];
          fileList.forEach((x) {

            if (x is File) {
              var res1 = ((x as File).readAsString()).then((value2) {
                Note note = Note.fromJsonResponse(value2);
                return note;
              }).catchError((error) {
                debugPrint('is not file content futurestring getNoteError: $x');
                return null;
              });
              var array2 = res1.then((value3) {
                array.add(value3);
                return array;
              });
            //?
            } else {
              debugPrint('is not file getNoteError: $x');
            }
          });


          // Add the file to the files array
          //Return the Future<List<Note>>
          return array;

        } catch (e) {
          debugPrint('getNoteError: $e');
          // If encountering an error, return 0
          return null;
        }
      } else {
        SimplePermissions.openSettings();
        return null;
      }
    });
  }
}

Очевидно, что это не будет работать, но даже попытка ожидания цикла с использованием закомментированных частей повышаетошибка.

В "getNotes" после проверки прав доступа я хочу получить массив всех файлов в каталоге, проанализировать их как объекты Note и вернуть полученный массив.

Iполучить список файлов: 

Stream<FileSystemEntity> fileList =
          Directory(file).list(recursive: false, followLinks: false);

И для каждого из них в потоке я хочу разобрать файл в объект и добавить его в массив для возврата в конце. 

       List<Note> array = [];
      fileList.forEach((x) {

        if (x is File) {
          var res1 = ((x as File).readAsString()).then((value2) {
            Note note = Note.fromJsonResponse(value2);
            return note;
          }).catchError((error) {
            debugPrint('is not file content futurestring getNoteError: $x');
            return null;
          });
          var array2 = res1.then((value3) {
            array.add(value3);
            return array;
          });
        //?
        } else {
          debugPrint('is not file getNoteError: $x');
        }
      });


      // Add the file to the files array
      //Return the Future<List<Note>>
      return array;

1 Ответ

0 голосов
/ 21 апреля 2019

Stream.forEach() возвращает Future. Ваш последний оператор return запускается сразу после вызова for-each, но должен await it. 

await fileList.forEach((x) {
  ...

https://api.dartlang.org/stable/2.2.0/dart-async/Stream/forEach.html

...