diff --git a/chronos/streams/asyncstream.nim b/chronos/streams/asyncstream.nim
index cc4695e..6fc194f 100644
--- a/chronos/streams/asyncstream.nim
+++ b/chronos/streams/asyncstream.nim
@@ -768,10 +768,11 @@ proc close*(rw: AsyncStreamRW) =
   if rw.closed():
     raise newAsyncStreamIncorrectError("Stream is already closed!")
 
+  rw.state = AsyncStreamState.Closed
+
   proc continuation(udata: pointer) =
     if not isNil(rw.udata):
       GC_unref(cast[ref int](rw.udata))
-    rw.state = AsyncStreamState.Closed
     if not(rw.future.finished()):
       rw.future.complete()
     when rw is AsyncStreamReader: