Блог

Мне нужна возможность синхронного чтения большого файла с разделителями табуляции по строке за раз. Я нашел это асинхронное решение. Можно ли выполнить синхронизацию с помощью await? Или есть лучший метод синхронизации?

 void readFileStream() {
  Stream<List<int>> stream = new File('./assets/user.json').openRead();
  StringBuffer buffer = new StringBuffer();
  stream
    .transform(utf8.decoder)
    .listen((data) {
      buffer.write(data);
    },
    onDone: () => print(buffer.toString()),
    onError: (e) => print(e));
}
  

Вы не можете сделать асинхронную операцию синхронной с помощью await или любым другим способом. Быть синхронным означает немедленное возвращение результата, быть асинхронным означает, что результат не доступен немедленно.

Для синхронного чтения вы можете читать по байту за раз, пока не дойдете до новой строки, но это, вероятно, будет очень медленно. Более разумный подход заключается в чтении фрагментов и разделении их на строки.

Может быть, что-то вроде:

 import "dart:io";
import "dart:convert";
import "dart:collection";

Iterable<String> readLinesSync(File file) sync* {
  var f = file.openSync(); // creates a RandomAccessFile
  var lineBuffer = Queue<String>();
  var sink = utf8.decoder.startChunkedConversion(
    LineSplitter().startChunkedConversion(_Sink(lineBuffer.add)));

  bool done = false;
  do {
    do {
      var chunk = f.readSync(256);
      sink.add(chunk);
      if (chunk.length < 256) {
        done = true;
        sink.close(); 
        break; 
      }
    } while (lineBuffer.isEmpty)
    while (lineBuffer.isNotEmpty) {
      yield lineBuffer.removeFirst(); 
    }
  } while (!done);
}

class _Sink<T> implements Sink<T> {
  void Function(T) _add;
  _Sink(this._add);
  void add(T value) {
    _add(value);
  }
  void close() {}
}