File tree 1 file changed +7
-5
lines changed
1 file changed +7
-5
lines changed Original file line number Diff line number Diff line change @@ -616,9 +616,15 @@ test('peer-discovery object deleted when corresponding connection closes (server
616
616
connected . pass ( 'swarm2' )
617
617
conn . on ( 'error' , noop )
618
618
} )
619
+
620
+ let resolveConnClosed = null
621
+ const connClosed = new Promise ( resolve => {
622
+ resolveConnClosed = resolve
623
+ } )
619
624
swarm1 . on ( 'connection' , ( conn ) => {
620
625
otherConnected . pass ( 'swarm1' )
621
626
conn . on ( 'error' , noop )
627
+ conn . on ( 'close' , resolveConnClosed )
622
628
} )
623
629
624
630
const topic = Buffer . alloc ( 32 ) . fill ( 'hello world' )
@@ -634,7 +640,7 @@ test('peer-discovery object deleted when corresponding connection closes (server
634
640
await swarm2 . destroy ( )
635
641
636
642
// Ensure other side detects closed connection
637
- await eventFlush ( )
643
+ await connClosed
638
644
639
645
t . is ( swarm1 . peers . size , 0 , 'No peerInfo memory leak' )
640
646
@@ -791,7 +797,3 @@ test('topic and peer get unslabbed in PeerInfo', async (t) => {
791
797
} )
792
798
793
799
function noop ( ) { }
794
-
795
- function eventFlush ( ) {
796
- return new Promise ( resolve => setImmediate ( resolve ) )
797
- }
You can’t perform that action at this time.
0 commit comments