logos-messaging/go-libp2p-pubsub
1
0
Fork 0
mirror of https://github.com/logos-messaging/go-libp2p-pubsub.git synced 2026-01-02 12:53:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

chore: go fmt

Browse Source
This commit is contained in:
galargh 2024-08-05 19:38:07 +02:00 committed by Steven Allen
parent 03952ea658
commit 435b99e317
2 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
subscription_filter_test.go
View File

@ -19,15 +19,15 @@ func TestBasicSubscriptionFilter(t *testing.T) {
topic3 := "test3"
yes := true
subs := []*pb.RPC_SubOpts{
&pb.RPC_SubOpts{
{
Topicid: &topic1,
Subscribe: &yes,
},
&pb.RPC_SubOpts{
{
Topicid: &topic2,
Subscribe: &yes,
},
&pb.RPC_SubOpts{
{
Topicid: &topic3,
Subscribe: &yes,
},
@ -108,24 +108,24 @@ func TestSubscriptionFilterDeduplication(t *testing.T) {
yes := true
no := false
subs := []*pb.RPC_SubOpts{
&pb.RPC_SubOpts{
{
Topicid: &topic1,
Subscribe: &yes,
},
&pb.RPC_SubOpts{
{
Topicid: &topic1,
Subscribe: &yes,
},
&pb.RPC_SubOpts{
{
Topicid: &topic2,
Subscribe: &yes,
},
&pb.RPC_SubOpts{
{
Topicid: &topic2,
Subscribe: &no,
},
&pb.RPC_SubOpts{
{
Topicid: &topic3,
Subscribe: &yes,
},

2
validation_builtin_test.go
View File

@ -246,7 +246,7 @@ func (r *replayActor) replay(msg *pb.Message) {
var peers []peer.ID
r.mx.Lock()
for p, _ := range r.out {
for p := range r.out {
if rng.Intn(2) > 0 {
peers = append(peers, p)
}