diff options
| author | Dominik Picheta <dominikpicheta@gmail.com> | 2017-02-26 12:52:19 +0100 |
|---|---|---|
| committer | Dominik Picheta <dominikpicheta@gmail.com> | 2017-02-26 12:52:19 +0100 |
| commit | f9cce320974c33554302d2a801c89e413c70a80b (patch) | |
| tree | cf951f97934e6d27ee517940197b08db1d6df44a /tests/async/tfuturestream.nim | |
| parent | 912d95a6ea2583bd783f85527dc3526b77710568 (diff) | |
| download | Nim-f9cce320974c33554302d2a801c89e413c70a80b.tar.gz | |
Various fixes to FutureStreams based on PR feedback.
Diffstat (limited to 'tests/async/tfuturestream.nim')
| -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 ce5cfec74..9a8e986a0 100644 --- a/tests/async/tfuturestream.nim +++ b/tests/async/tfuturestream.nim @@ -19,14 +19,14 @@ var fs = newFutureStream[int]() proc alpha() {.async.} = for i in 0 .. 5: await sleepAsync(1000) - await fs.put(i) + await fs.write(i) echo("Done") fs.complete() proc beta() {.async.} = while not fs.finished: - let (hasValue, value) = await fs.take() + let (hasValue, value) = await fs.read() if hasValue: echo(value) |