commit 231e65cbee654c098ed85b26e9ac2a179456a08f
author Konstantin Shcheglov <scheglov@google.com> Tue Dec 15 15:17:21 2020 -0800
committer Konstantin Shcheglov <scheglov@google.com> Tue Dec 15 15:17:21 2020 -0800
tree 1688cfc3a89d3d24b58154cc2a5ccf5e725ae480
parent 0be2281c8aecc81bacab32227b50d64a259d73e9

Move '_filesToProcess' initializer.

lib/src/directory_watcher/polling.dart

diff --git a/lib/src/directory_watcher/polling.dart b/lib/src/directory_watcher/polling.dart
index 6baa49d..95fb683 100644
--- a/lib/src/directory_watcher/polling.dart
+++ b/lib/src/directory_watcher/polling.dart
@@ -70,7 +70,10 @@
   /// queue exists to let each of those proceed at their own rate. The lister
   /// will enqueue files as quickly as it can. Meanwhile, files are dequeued
   /// and processed sequentially.
-  late final AsyncQueue<String?> _filesToProcess;
+  late final AsyncQueue<String?> _filesToProcess = AsyncQueue<String?>(
+      _processFile, onError: (Object e, StackTrace stackTrace) {
+    if (!_events.isClosed) _events.addError(e, stackTrace);
+  });
 
   /// The set of files that have been seen in the current directory listing.
   ///
@@ -79,11 +82,6 @@
   final _polledFiles = <String>{};
 
   _PollingDirectoryWatcher(this.path, this._pollingDelay) {
-    _filesToProcess = AsyncQueue<String?>(_processFile,
-        onError: (Object e, StackTrace stackTrace) {
-      if (!_events.isClosed) _events.addError(e, stackTrace);
-    });
-
     _poll();
   }