make the logic right

This commit is contained in:
Araq
2017-02-26 13:28:46 +01:00
parent b5de988eda
commit 48c50f6b41

View File

@@ -297,7 +297,7 @@ proc read*[T](future: FutureStream[T]): Future[(bool, T)] =
res[0] = false
else:
res[0] = true
res[1] = fs.queue.popLast()
res[1] = fs.queue.popFirst()
if not resFut.finished:
resFut.complete(res)