Skip to content

Commit

Permalink
Reverts 1446dc8. Fixes #4333. Fixes #4170.
Browse files Browse the repository at this point in the history
  • Loading branch information
dom96 committed Jun 15, 2016
1 parent 5f83e86 commit 500aa0c
Show file tree
Hide file tree
Showing 3 changed files with 65 additions and 6 deletions.
10 changes: 4 additions & 6 deletions lib/pure/asyncdispatch.nim
Expand Up @@ -1526,13 +1526,11 @@ proc processBody(node, retFutureSym: NimNode,
case node[1].kind
of nnkIdent, nnkInfix:
# await x
result = newNimNode(nnkStmtList, node)
var futureValue: NimNode
result.useVar(node[1], futureValue, futureValue, node)
# -> yield x
# -> x.read()
# await x or y
result = newNimNode(nnkYieldStmt, node).add(node[1]) # -> yield x
of nnkCall, nnkCommand:
# await foo(p, x)
# await foo p, x
var futureValue: NimNode
result.createVar("future" & $node[1][0].toStrLit, node[1], futureValue,
futureValue, node)
Expand Down Expand Up @@ -1738,7 +1736,7 @@ proc asyncSingleProc(prc: NimNode): NimNode {.compileTime.} =
result[6] = outerProcBody

#echo(treeRepr(result))
#if prc[0].getName == "g":
#if prc[0].getName == "testInfix":
# echo(toStrLit(result))

macro async*(prc: stmt): stmt {.immediate.} =
Expand Down
2 changes: 2 additions & 0 deletions tests/async/tasyncexceptions.nim
Expand Up @@ -5,6 +5,8 @@ discard """
"""
import asyncdispatch

# Note: This is a test case for a bug.

proc accept(): Future[int] {.async.} =
await sleepAsync(100)
result = 4
Expand Down
59 changes: 59 additions & 0 deletions tests/async/tawaitsemantics.nim
@@ -0,0 +1,59 @@
discard """
file: "tawaitsemantics.nim"
exitcode: 0
output: '''
Error caught
Test infix
Test call
'''
"""

import asyncdispatch

# This tests the behaviour of 'await' under different circumstances.
# For example, when awaiting Future variable and this future has failed the
# exception shouldn't be raised as described here
# https://github.com/nim-lang/Nim/issues/4170

proc thrower(): Future[void] =
result = newFuture[void]()
result.fail(newException(Exception, "Test"))

proc dummy: Future[void] =
result = newFuture[void]()
result.complete()

proc testInfix() {.async.} =
# Test the infix operator semantics.
var fut = thrower()
var fut2 = dummy()
await fut or fut2 # Shouldn't raise.
# TODO: what about: await thrower() or fut2?

proc testCall() {.async.} =
await thrower()

proc tester() {.async.} =
# Test that we can handle exceptions without 'try'
var fut = thrower()
doAssert fut.finished
doAssert fut.failed
doAssert fut.error.msg == "Test"
await fut # We are awaiting a 'Future', so no `read` occurs.
doAssert fut.finished
doAssert fut.failed
doAssert fut.error.msg == "Test"
echo("Error caught")

fut = testInfix()
await fut
doAssert fut.finished
doAssert(not fut.failed)
echo("Test infix")

fut = testCall()
await fut
doAssert fut.failed
echo("Test call")

waitFor(tester())

0 comments on commit 500aa0c

Please sign in to comment.