diff --git a/libp2p/stream/chronosstream.nim b/libp2p/stream/chronosstream.nim
index b3af6b682..b9baa1968 100644
--- a/libp2p/stream/chronosstream.nim
+++ b/libp2p/stream/chronosstream.nim
@@ -16,6 +16,12 @@ logScope:
 type ChronosStream* = ref object of LPStream
     client: StreamTransport
 
+proc onTransportClose(s: ChronosStream,
+                      client: StreamTransport) {.async.} =
+  await client.join()
+  trace "Transport closed, closing connection"
+  await s.close()
+
 proc newChronosStream*(client: StreamTransport): ChronosStream =
   new result
   result.client = client