@libp2p/interface - npm Package Compare versions

Comparing version 0.1.0 to 0.1.1-6b839807

dist/src/connection/index.d.ts

@@ -221,10 +221,2 @@ import type { AbortOptions } from '../index.js';
     /**
-     * Add a stream to this connection
-     */
-    addStream: (stream: Stream) => void;
-    /**
-     * Remove a stream from this connection
-     */
-    removeStream: (id: string) => void;
-    /**
      * Gracefully close the connection. All queued data will be written to the
@@ -231,0 +223,0 @@ * underlying transport.

dist/src/stream-muxer/stream.js

@@ -169,3 +169,3 @@ import { abortableSource } from 'abortable-iterator';
         }
-        if (this.status !== 'reset' && this.status !== 'aborted') {
+        if (this.status !== 'reset' && this.status !== 'aborted' && this.timeline.closeRead == null) {
             this.log.trace('send close read to remote');
@@ -199,3 +199,3 @@ await this.sendCloseRead(options);
         }
-        if (this.status !== 'reset' && this.status !== 'aborted') {
+        if (this.status !== 'reset' && this.status !== 'aborted' && this.timeline.closeWrite == null) {
             this.log.trace('send close write to remote');
@@ -202,0 +202,0 @@ await this.sendCloseWrite(options);

package.json

 {
   "name": "@libp2p/interface",
-  "version": "0.1.0",
+  "version": "0.1.1-6b839807",
   "description": "The interface implemented by a libp2p node",
@@ -5,0 +5,0 @@ "license": "Apache-2.0 OR MIT",

src/connection/index.ts

@@ -262,12 +262,2 @@ import type { AbortOptions } from '../index.js'
   /**
-   * Add a stream to this connection
-   */
-  addStream: (stream: Stream) => void
-
-  /**
-   * Remove a stream from this connection
-   */
-  removeStream: (id: string) => void
-
-  /**
    * Gracefully close the connection. All queued data will be written to the
@@ -274,0 +264,0 @@ * underlying transport.

src/stream-muxer/stream.ts

@@ -274,3 +274,3 @@ import { abortableSource } from 'abortable-iterator'
 
-    if (this.status !== 'reset' && this.status !== 'aborted') {
+    if (this.status !== 'reset' && this.status !== 'aborted' && this.timeline.closeRead == null) {
       this.log.trace('send close read to remote')
@@ -312,3 +312,3 @@ await this.sendCloseRead(options)
 
-    if (this.status !== 'reset' && this.status !== 'aborted') {
+    if (this.status !== 'reset' && this.status !== 'aborted' && this.timeline.closeWrite == null) {
       this.log.trace('send close write to remote')
@@ -315,0 +315,0 @@ await this.sendCloseWrite(options)

New alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Fixed alerts

License Policy Violation

License

This package is not allowed per your license policy. Review the package's license to ensure compliance.

Found 1 instance in 1 package

Worsened metrics

Total package byte prevSize

253703

decreased by-0.11%

Lines of code

6091

decreased by-0.26%

Published versions last two months

67

decreased by-2.9%

Published versions last year

322

decreased by-4.73%

No dependency changes