@@ -4,6 +4,7 @@ import pair from 'it-pair/duplex.js'
4
4
import { pipe } from 'it-pipe'
5
5
import { collect , map , consume } from 'streaming-iterables'
6
6
import defer from 'p-defer'
7
+ import type { DeferredPromise } from 'p-defer'
7
8
import type { TestSetup } from '../index.js'
8
9
import type { Muxer , MuxerOptions , MuxedStream } from '@libp2p/interfaces/stream-muxer'
9
10
import { isValidTick } from '../transport/utils/index.js'
@@ -17,8 +18,8 @@ export default (common: TestSetup<Muxer, MuxerOptions>) => {
17
18
it ( 'Open a stream from the dialer' , async ( ) => {
18
19
const p = pair ( )
19
20
const dialer = await common . setup ( )
20
- const onStreamPromise : defer . DeferredPromise < MuxedStream > = defer ( )
21
- const onStreamEndPromise : defer . DeferredPromise < MuxedStream > = defer ( )
21
+ const onStreamPromise : DeferredPromise < MuxedStream > = defer ( )
22
+ const onStreamEndPromise : DeferredPromise < MuxedStream > = defer ( )
22
23
23
24
const listener = await common . setup ( {
24
25
onStream : stream => {
@@ -62,7 +63,7 @@ export default (common: TestSetup<Muxer, MuxerOptions>) => {
62
63
63
64
it ( 'Open a stream from the listener' , async ( ) => {
64
65
const p = pair ( )
65
- const onStreamPromise : defer . DeferredPromise < MuxedStream > = defer ( )
66
+ const onStreamPromise : DeferredPromise < MuxedStream > = defer ( )
66
67
const dialer = await common . setup ( {
67
68
onStream : stream => {
68
69
onStreamPromise . resolve ( stream )
@@ -87,8 +88,8 @@ export default (common: TestSetup<Muxer, MuxerOptions>) => {
87
88
88
89
it ( 'Open a stream on both sides' , async ( ) => {
89
90
const p = pair ( )
90
- const onDialerStreamPromise : defer . DeferredPromise < MuxedStream > = defer ( )
91
- const onListenerStreamPromise : defer . DeferredPromise < MuxedStream > = defer ( )
91
+ const onDialerStreamPromise : DeferredPromise < MuxedStream > = defer ( )
92
+ const onListenerStreamPromise : DeferredPromise < MuxedStream > = defer ( )
92
93
const dialer = await common . setup ( {
93
94
onStream : stream => {
94
95
onDialerStreamPromise . resolve ( stream )
@@ -119,8 +120,8 @@ export default (common: TestSetup<Muxer, MuxerOptions>) => {
119
120
it ( 'Open a stream on one side, write, open a stream on the other side' , async ( ) => {
120
121
const toString = map ( ( c : string ) => c . slice ( ) . toString ( ) )
121
122
const p = pair ( )
122
- const onDialerStreamPromise : defer . DeferredPromise < MuxedStream > = defer ( )
123
- const onListenerStreamPromise : defer . DeferredPromise < MuxedStream > = defer ( )
123
+ const onDialerStreamPromise : DeferredPromise < MuxedStream > = defer ( )
124
+ const onListenerStreamPromise : DeferredPromise < MuxedStream > = defer ( )
124
125
const dialer = await common . setup ( {
125
126
onStream : stream => {
126
127
onDialerStreamPromise . resolve ( stream )
0 commit comments