From 473a5d287349ce8e8506daded9c2a713d81f0dd5 Mon Sep 17 00:00:00 2001 From: vyzo Date: Sat, 13 Jan 2018 21:39:35 +0200 Subject: [PATCH] sendMsg should have a buffer --- floodsub.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/floodsub.go b/floodsub.go index 45ade9c..8455dad 100644 --- a/floodsub.go +++ b/floodsub.go @@ -104,7 +104,7 @@ func NewFloodSub(ctx context.Context, h host.Host, opts ...Option) (*PubSub, err getPeers: make(chan *listPeerReq), addSub: make(chan *addSubReq), getTopics: make(chan *topicReq), - sendMsg: make(chan *sendReq), + sendMsg: make(chan *sendReq, 32), validateThrottle: make(chan struct{}, defaultValidateThrottle), myTopics: make(map[string]map[*Subscription]struct{}), topics: make(map[string]map[peer.ID]struct{}),