From 50076102acc681ebdbce545ce28b29990364a964 Mon Sep 17 00:00:00 2001
From: Simon Binder <simolus3@gmail.com>
Date: Sun, 31 Mar 2019 18:58:08 +0200
Subject: [PATCH] Fix concurrent modification in stream query store

closes #13
---
 moor/lib/src/runtime/executor/stream_queries.dart | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/moor/lib/src/runtime/executor/stream_queries.dart b/moor/lib/src/runtime/executor/stream_queries.dart
index 6b80c29c..6992f22f 100644
--- a/moor/lib/src/runtime/executor/stream_queries.dart
+++ b/moor/lib/src/runtime/executor/stream_queries.dart
@@ -88,7 +88,8 @@ class StreamQueryStore {
   /// Handles updates on a given table by re-executing all queries that read
   /// from that table.
   Future<void> handleTableUpdates(Set<TableInfo> tables) async {
-    final affectedStreams = _activeStreams
+    final activeStreams = List<QueryStream>.from(_activeStreams);
+    final affectedStreams = activeStreams
         .where((stream) => stream._fetcher.readsFrom.any(tables.contains));
 
     for (var stream in affectedStreams) {