File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change 188
188
"@libp2p/peer-id" : " ^2.0.0" ,
189
189
"@libp2p/topology" : " ^4.0.0" ,
190
190
"abortable-iterator" : " ^4.0.2" ,
191
- "it-length-prefixed" : " ^8 .0.2 " ,
191
+ "it-length-prefixed" : " ^9 .0.0 " ,
192
192
"it-pipe" : " ^3.0.0" ,
193
193
"it-pushable" : " ^3.0.0" ,
194
194
"multiformats" : " ^11.0.0" ,
Original file line number Diff line number Diff line change @@ -94,7 +94,7 @@ export class PeerStreams extends EventEmitter<PeerStreamEvents> {
94
94
this . inboundStream = abortableSource (
95
95
pipe (
96
96
this . _rawInboundStream ,
97
- lp . decode ( )
97
+ ( source ) => lp . decode ( source )
98
98
) ,
99
99
this . _inboundAbortController . signal ,
100
100
{ returnOnAbort : true }
@@ -134,7 +134,7 @@ export class PeerStreams extends EventEmitter<PeerStreamEvents> {
134
134
135
135
pipe (
136
136
this . outboundStream ,
137
- lp . encode ( ) ,
137
+ ( source ) => lp . encode ( source ) ,
138
138
this . _rawOutboundStream
139
139
) . catch ( ( err : Error ) => {
140
140
log . error ( err )
You can’t perform that action at this time.
0 commit comments