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

Merge pull request #4370 from edubart/future-withtimeout

Browse source 
Add withTimeout proc for futures
This commit is contained in:
Dominik Picheta 2016-06-19 22:58:14 +01:00 • committed by GitHub
commit f76112fb01
1 changed files with 18 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

18
lib/pure/asyncdispatch.nim
View file

@ -1542,6 +1542,24 @@ proc sleepAsync*(ms: int): Future[void] =
p.timers.push((epochTime() + (ms / 1000), retFuture))
return retFuture
proc withTimeout*[T](fut: Future[T], timeout: int): Future[bool] =
## Returns a future which will complete once ``fut`` completes or after
## ``timeout`` milliseconds has elapsed.
##
## If ``fut`` completes first the returned future will hold true,
## otherwise, if ``timeout`` milliseconds has elapsed first, the returned
## future will hold false.
var retFuture = newFuture[bool]("asyncdispatch.`withTimeout`")
var timeoutFuture = sleepAsync(timeout)
fut.callback =
proc () =
if not retFuture.finished: retFuture.complete(true)
timeoutFuture.callback =
proc () =
if not retFuture.finished: retFuture.complete(false)
return retFuture
proc accept*(socket: AsyncFD,
flags = {SocketFlag.SafeDisconn}): Future[AsyncFD] =
## Accepts a new connection. Returns a future containing the client socket