fix closed

Author: vladopajic

libp2p/transports/quictransport.nim

@@ -111,14 +111,16 @@ method closeImpl*(stream: QuicStream) {.async: (raises: []).} =
 
 # Session
 type QuicSession* = ref object of P2PConnection
-  connection*: QuicConnection
+  connection: QuicConnection
   streams: seq[QuicStream]
 
+method closed*(session: QuicSession): bool {.raises: [].} =
+  procCall P2PConnection(session).isClosed or session.connection.isClosed
+
 method close*(session: QuicSession) {.async: (raises: []).} =
   for s in session.streams:
     await s.close()
-  if session != nil:
-    session.connection.close()
+  session.connection.close()
   await procCall P2PConnection(session).close()
 
 proc getStream(
@@ -187,7 +189,7 @@ method handle*(m: QuicMuxer): Future[void] {.async: (raises: []).} =
     trace "finished handling stream"
     doAssert(stream.closed, "connection not closed by handler!")
 
-  while not (m.session.atEof or m.session.connection.isClosed):
+  while not (m.session.atEof or m.session.closed):
     try:
       let stream = await m.session.getStream(Direction.In)
       asyncSpawn handleStream(stream)

tests/transports/testquic.nim

@@ -81,9 +81,7 @@ suite "Quic transport":
       # validates the certificate, it will close the connection
       # hence why a sleep is necessary
       await sleepAsync(100.milliseconds)
-      let isClosed = (cast[QuicSession](conn)).connection.isClosed
-      check:
-        isClosed
+      check (cast[QuicSession](conn)).closed()
       await client.stop()
 
     await runClient()