jyapayne/Nim
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

Fix FutureStream memory usage (#17395) [backport:1.2]

Browse source
This commit is contained in:
Igor Ribeiro de Assis 2021-03-16 21:46:22 +01:00 • committed by GitHub
commit 9bb0e55749
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
1 changed files with 5 additions and 1 deletions
Download patch file Download diff file Expand all files Collapse all files

6
lib/pure/asyncstreams.nim
View file

@ -127,7 +127,11 @@ proc read*[T](future: FutureStream[T]): owned(Future[(bool, T)]) =
resFut.complete(res) resFut.complete(res)
# If the saved callback isn't nil then let's call it. # If the saved callback isn't nil then let's call it.
if not savedCb.isNil: savedCb() if not savedCb.isNil:
if fs.queue.len > 0:
savedCb()
else:
future.cb = savedCb
if future.queue.len > 0 or future.finished: if future.queue.len > 0 or future.finished:
newCb(future) newCb(future)