From dfa2aed92a4ad7a96d05b8607a9d5207a183532b Mon Sep 17 00:00:00 2001 From: Aratz Manterola Lasa Date: Fri, 29 Jul 2022 07:17:31 +0200 Subject: [PATCH] pubsub flow limiter is at least 1 --- pkg/vat/cap/pubsub/server.go | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) diff --git a/pkg/vat/cap/pubsub/server.go b/pkg/vat/cap/pubsub/server.go index e7024c6c..c93233fa 100644 --- a/pkg/vat/cap/pubsub/server.go +++ b/pkg/vat/cap/pubsub/server.go @@ -240,7 +240,11 @@ func (t *refCountedTopic) subscribe(args api.Topic_subscribe_Params) (s subscrip if s.sub, err = t.topic.Subscribe(pubsub.WithBufferSize(int(subOpts.BufferSize()))); err == nil { s.ch = channel.Sender(args.Chan().AddRef()) - s.ch.Client.SetFlowLimiter(newFlowLimiter(subOpts.BufferSize())) + if subOpts.BufferSize() < 1 { + s.ch.Client.SetFlowLimiter(newFlowLimiter(1)) // limiter must be at least 1 + } else { + s.ch.Client.SetFlowLimiter(newFlowLimiter(subOpts.BufferSize())) + } t.ref++ s.t = t