chore: fix

achingbrain · achingbrain · commit e7f8807fd8c0 · 2025-10-01T11:51:13.000+03:00
diff --git a/packages/utils/src/stream-utils.ts b/packages/utils/src/stream-utils.ts
@@ -96,7 +96,7 @@ function isMultiaddrConnection (obj?: any): obj is MultiaddrConnection {
 
 function isEOF (obj?: any): boolean {
   if (isStream(obj)) {
-    return obj.remoteWriteStatus !== 'writable'
+    return obj.readStatus === 'closing' || obj.readStatus === 'closed' || obj.remoteWriteStatus !== 'writable'
   }
 
   if (isMultiaddrConnection(obj)) {

Original file line number	Diff line number	Diff line change
`@@ -96,7 +96,7 @@ function isMultiaddrConnection (obj?: any): obj is MultiaddrConnection {`
`96`	`96`
`97`	`97`	`function isEOF (obj?: any): boolean {`
`98`	`98`	`if (isStream(obj)) {`
`99`		`- return obj.remoteWriteStatus !== 'writable'`
	`99`	`+ return obj.readStatus === 'closing' \|\| obj.readStatus === 'closed' \|\| obj.remoteWriteStatus !== 'writable'`
`100`	`100`	`}`
`101`	`101`
`102`	`102`	`if (isMultiaddrConnection(obj)) {`