update workflows

Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-10-27 17:47:25 +03:00
parent 2c74b3232b
commit 6ce9ed8e84
3 changed files with 33 additions and 65 deletions
--- a/options.go
+++ b/options.go
@@ -59,7 +59,7 @@ var DefaultSubscribeMaxInflight = 1000

 type subscribeMaxInflightKey struct{}

-// SubscribeMaxInFlight specifies interval to send commits
+// SubscribeMaxInFlight max queued messages
 func SubscribeMaxInFlight(n int) broker.SubscribeOption {
 	return broker.SetSubscribeOption(subscribeMaxInflightKey{}, n)
 }