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

sttdlib: asyncdispatch: all: Add Future[void] support.

Browse source
This commit is contained in:
Konstantin Molchanov 2016-05-31 22:33:51 +04:00
commit f44e065356
1 changed files with 19 additions and 15 deletions
Download patch file Download diff file Expand all files Collapse all files

8
lib/pure/asyncdispatch.nim
View file

@ -9,7 +9,7 @@
include "system/inclrtl" include "system/inclrtl"
import os, oids, tables, strutils, macros, times, heapqueue import os, oids, tables, strutils, macros, times, heapqueue, sequtils
import nativesockets, net, queues import nativesockets, net, queues
@ -355,13 +355,17 @@ proc `or`*[T, Y](fut1: Future[T], fut2: Future[Y]): Future[void] =
fut2.callback = cb fut2.callback = cb
return retFuture return retFuture
proc all*[T](futs: varargs[Future[T]]): Future[seq[T]] = proc all*[T](futs: varargs[Future[T]]): auto =
## Returns a future which will complete once all futures in ``futs`` ## Returns a future which will complete once all futures in ``futs``
## complete. ## complete.
## ##
## The resulting future will hold the values of all awaited futures, ## The resulting future will hold the values of all awaited futures,
## in the order they are passed. ## in the order they are passed.
when T is void:
return foldl(futs, a and b)
else:
var var
retFuture = newFuture[seq[T]]("asyncdispatch.all") retFuture = newFuture[seq[T]]("asyncdispatch.all")
retValues = newSeq[T](len(futs)) retValues = newSeq[T](len(futs))