fix(ping): gracefully handle remote stream closure.

packages/protocol-ping/src/ping.ts

@@ -70,11 +70,26 @@ export class PingService implements Startable, PingServiceInterface {
 
         const buf = await bytes.read(PING_LENGTH, {
           signal
+        }).catch((err: Error) => {
+          if (stream.readStatus === 'ready') throw err
+          return null
         })
+
+        if (buf === null) break
+
         await bytes.write(buf, {
           signal
         })
       }
+      // close the stream
+      if (stream.status === 'open') {
+        const signal = AbortSignal.timeout(this.timeout)
+        signal.addEventListener('abort', () => {
+          stream?.abort(new TimeoutError('close timeout'))
+        })
+
+        await stream.close({ signal })
+      }
     })
       .catch(err => {
         this.log.error('incoming ping from %p failed with error', data.connection.remotePeer, err)