fix dangling maxConcurrency reference

2018-01-13 12:24:31 +02:00 · 2018-01-13 12:24:31 +02:00 · 4241241031
parent 88274db0bb
commit 4241241031
1 changed files with 1 additions and 1 deletions
--- a/floodsub.go
+++ b/floodsub.go
@ -116,7 +116,7 @@ func NewFloodSub(ctx context.Context, h host.Host, opts ...Option) (*PubSub, err
 		peers:            make(map[peer.ID]chan *RPC),
 		seenMessages:     timecache.NewTimeCache(time.Second * 30),
 		counter:          uint64(time.Now().UnixNano()),
-		throttleValidate: make(chan struct{}, maxConcurrency),
+		throttleValidate: make(chan struct{}, defaultMaxConcurrency),
 	}

 	for _, opt := range opts {