reset the read flag

tailcallhq · Oct 25, 2024 · 89314af · 89314af
1 parent cc72255
commit 89314af
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/src/core/data_loader/dedupe.rs b/src/core/data_loader/dedupe.rs
@@ -63,7 +63,9 @@ impl<K: Key, V: Value> Dedupe<K, V> {
     {
         let mut read = true;
         loop {
-            let value = match self.step(key, read) {
+            let step = self.step(key, read);
+            read = true;
+            let value = match step {
                 Step::Return(value) => value,
                 Step::Await(mut rx) => match rx.recv().await {
                     Ok(value) => value,