diff --git a/broker/options.go b/broker/options.go index 2c6a58c0..c1f3588c 100644 --- a/broker/options.go +++ b/broker/options.go @@ -80,6 +80,12 @@ func Context(ctx context.Context) Option { } } +func GracefulTimeout(t time.Duration) Option { + return func(o *Options) { + o.GracefulTimeout = t + } +} + // ContentType used by default if not specified func ContentType(ct string) Option { return func(o *Options) {