fix: dispatch_timeout and heartbeat

dunglas · Apr 20, 2023 · 86a6f5f · 86a6f5f
1 parent f64e644
commit 86a6f5f
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 2 deletions.
diff --git a/caddy/caddy.go b/caddy/caddy.go
@@ -63,7 +63,7 @@ type Mercure struct {
 	// Maximum duration before closing the connection, defaults to 600s, set to 0 to disable.
 	WriteTimeout *caddy.Duration `json:"write_timeout,omitempty"`
 
-	// Maximum dispatch duration of an update.
+	// Maximum dispatch duration of an update, defaults to 5s.
 	DispatchTimeout *caddy.Duration `json:"dispatch_timeout,omitempty"`
 
 	// Frequency of the heartbeat, defaults to 40s.

diff --git a/hub.go b/hub.go
@@ -284,7 +284,11 @@ type Hub struct {
 
 // NewHub creates a new Hub instance.
 func NewHub(options ...Option) (*Hub, error) {
-	opt := &opt{writeTimeout: 600 * time.Second}
+	opt := &opt{
+		writeTimeout:    600 * time.Second,
+		dispatchTimeout: 5 * time.Second,
+		heartbeat:       40 * time.Second,
+	}
 
 	for _, o := range options {
 		if err := o(opt); err != nil {