diff --git a/asyncdispatch2.nimble b/asyncdispatch2.nimble
index 4f2d969..6818d3e 100644
--- a/asyncdispatch2.nimble
+++ b/asyncdispatch2.nimble
@@ -1,5 +1,5 @@
 packageName   = "asyncdispatch2"
-version       = "2.1.0"
+version       = "2.1.1"
 author        = "Status Research & Development GmbH"
 description   = "Asyncdispatch2"
 license       = "Apache License 2.0 or MIT"
diff --git a/asyncdispatch2/transports/datagram.nim b/asyncdispatch2/transports/datagram.nim
index cc7c094..3f6dcf1 100644
--- a/asyncdispatch2/transports/datagram.nim
+++ b/asyncdispatch2/transports/datagram.nim
@@ -572,6 +572,7 @@ proc join*(transp: DatagramTransport): Future[void] =
 
 proc closeWait*(transp: DatagramTransport): Future[void] =
   ## Close transport ``transp`` and release all resources.
+  transp.close()
   result = transp.join()
 
 proc send*(transp: DatagramTransport, pbytes: pointer,
diff --git a/asyncdispatch2/transports/stream.nim b/asyncdispatch2/transports/stream.nim
index c0268d7..0d79be0 100644
--- a/asyncdispatch2/transports/stream.nim
+++ b/asyncdispatch2/transports/stream.nim
@@ -806,6 +806,7 @@ proc close*(server: StreamServer) =
 
 proc closeWait*(server: StreamServer): Future[void] =
   ## Close server ``server`` and release all resources.
+  server.close()
   result = server.join()
 
 proc createStreamServer*(host: TransportAddress,
@@ -1264,6 +1265,7 @@ proc close*(transp: StreamTransport) =
 
 proc closeWait*(transp: StreamTransport): Future[void] =
   ## Close and frees resources of transport ``transp``.
+  transp.close()
   result = transp.join()
 
 proc closed*(transp: StreamTransport): bool {.inline.} =