fix type mismatch error in asyncstream join (#433)
This commit is contained in:
parent
a1eb30360b
commit
38c31e21d3
|
@ -873,10 +873,10 @@ proc join*(rw: AsyncStreamRW): Future[void] =
|
|||
else:
|
||||
var retFuture = newFuture[void]("async.stream.writer.join")
|
||||
|
||||
proc continuation(udata: pointer) {.gcsafe.} =
|
||||
proc continuation(udata: pointer) {.gcsafe, raises:[].} =
|
||||
retFuture.complete()
|
||||
|
||||
proc cancellation(udata: pointer) {.gcsafe.} =
|
||||
proc cancellation(udata: pointer) {.gcsafe, raises:[].} =
|
||||
rw.future.removeCallback(continuation, cast[pointer](retFuture))
|
||||
|
||||
if not(rw.future.finished()):
|
||||
|
|
Loading…
Reference in New Issue