File tree Expand file tree Collapse file tree 2 files changed +3
-3
lines changed
Sources/LibP2PPubSub/Routers/Gossipsub/PeerStore Expand file tree Collapse file tree 2 files changed +3
-3
lines changed Original file line number Diff line number Diff line change @@ -31,7 +31,7 @@ let package = Package(
31
31
dependencies: [
32
32
// Dependencies declare other packages that this package depends on.
33
33
. package ( url: " https://github.com/swift-libp2p/swift-libp2p.git " , . upToNextMinor( from: " 0.2.0 " ) ) ,
34
-
34
+
35
35
// Test dependencies
36
36
. package ( url: " https://github.com/swift-libp2p/swift-libp2p-noise.git " , . upToNextMinor( from: " 0.1.0 " ) ) ,
37
37
. package ( url: " https://github.com/swift-libp2p/swift-libp2p-mplex.git " , . upToNextMinor( from: " 0.1.0 " ) ) ,
Original file line number Diff line number Diff line change @@ -372,15 +372,15 @@ class PeeringState: PeerStateProtocol {
372
372
eventLoop. submit { ( ) -> [ PeerID ] in
373
373
let subbed = self . mesh [ topic] ?? [ ]
374
374
//let known = self.fanout[topic] ?? []
375
- return self . idsToPeers ( subbed) // known
375
+ return self . idsToPeers ( subbed) // known
376
376
} . hop ( to: loop ?? eventLoop)
377
377
}
378
378
379
379
func peersSubscribedTo( topic: String , on loop: EventLoop ? ) -> EventLoopFuture < [ PubSub . Subscriber ] > {
380
380
eventLoop. submit { ( ) -> [ PubSub . Subscriber ] in
381
381
let subbed = self . mesh [ topic] ?? [ ]
382
382
//let known = self.fanout[topic] ?? []
383
- return self . idsToSubs ( subbed) // known
383
+ return self . idsToSubs ( subbed) // known
384
384
} . hop ( to: loop ?? eventLoop)
385
385
}
386
386
You can’t perform that action at this time.
0 commit comments