diff --git a/exchange/options.go b/exchange/options.go index 6b3f9ac..4e7ed51 100644 --- a/exchange/options.go +++ b/exchange/options.go @@ -40,7 +40,7 @@ func newOptions(o ...Option) (*options, error) { ipniPublishMaxBatchSize: 16 << 10, ipniPublishChanBuffer: 1, wg: nil, - pushRateLimiter: ratelimit.New(5), // Default of 5 per second + pushRateLimiter: ratelimit.New(1000), // Default of 5 per second } for _, apply := range o { if err := apply(&opts); err != nil {