diff --git a/stream.go b/stream.go index 04a32fc2..f11004bc 100644 --- a/stream.go +++ b/stream.go @@ -12,7 +12,7 @@ import ( ) var ( - emptyMessagesLimit = 100 + emptyMessagesLimit = 300 ErrTooManyEmptyStreamMessages = errors.New("stream has sent too many empty messages") )