fixes #14402 (#14908)

* fixes #14402 * added a test case
2020-07-08 08:21:55 +02:00 · 2020-07-08 08:21:55 +02:00 · 87f6a9592c
commit 87f6a9592c
parent e82a14b273
2 changed files with 27 additions and 1 deletions
--- a/lib/pure/asyncstreams.nim
+++ b/lib/pure/asyncstreams.nim
@ -96,7 +96,7 @@ proc read*[T](future: FutureStream[T]): owned(Future[(bool, T)]) =
      if resFut.finished: return

      # We don't want this callback called again.
-      future.cb = nil
+      #future.cb = nil

      # The return value depends on whether the FutureStream has finished.
      var res: (bool, T)