diff options
| author | Dominik Picheta <dominikpicheta@gmail.com> | 2017-02-10 20:40:32 +0100 |
|---|---|---|
| committer | Dominik Picheta <dominikpicheta@gmail.com> | 2017-02-10 20:40:32 +0100 |
| commit | 2f502e2a9ede75be3f56a0206e1314c758e1ad90 (patch) | |
| tree | 587378ca25c56289a4a8deadf40b18311b3d7763 /tests | |
| parent | ddd3d3f44a7bd83d97e17b46bc7fd6b92043520f (diff) | |
| download | Nim-2f502e2a9ede75be3f56a0206e1314c758e1ad90.tar.gz | |
Remove immediate FutureStream procs and make 'put' awaitable.
Diffstat (limited to 'tests')
| -rw-r--r-- | tests/async/tfuturestream.nim | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/tests/async/tfuturestream.nim b/tests/async/tfuturestream.nim index 61b3863ac..bf8c9b4c4 100644 --- a/tests/async/tfuturestream.nim +++ b/tests/async/tfuturestream.nim @@ -19,13 +19,13 @@ var fs = newFutureStream[int]() proc alpha() {.async.} = for i in 0 .. 5: await sleepAsync(1000) - fs.put(i) + await fs.put(i) fs.complete() proc beta() {.async.} = while not fs.finished: - let (hasValue, value) = await fs.takeAsync() + let (hasValue, value) = await fs.take() if hasValue: echo(value) |