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

Stdlib: asyncdispatch: all proc: Fix incorect counter value issue.

Browse source
This commit is contained in:
Konstantin Molchanov 2016-05-31 14:56:45 +04:00
commit 5a007a84fc
1 changed files with 8 additions and 5 deletions
Download patch file Download diff file Expand all files Collapse all files

13
lib/pure/asyncdispatch.nim
View file

@ -368,12 +368,15 @@ proc all*[A](futs: openarray[Future[A]]): Future[seq[A]] =
completedFutures = 0
for i, fut in futs:
fut.callback = proc(f: Future[A]) =
retValues[i] = f.read()
inc(completedFutures)
proc setCallback(i: int) =
fut.callback = proc(f: Future[A]) =
retValues[i] = f.read()
inc(completedFutures)
if completedFutures == len(futs):
retFuture.complete(retValues)
if completedFutures == len(retValues):
retFuture.complete(retValues)
setCallback(i)
return retFuture