feat(p2p): add subscriber params override opt

celestiaorg · Oct 12, 2023 · 074f77f · 074f77f
1 parent 27e85f9
commit 074f77f
Showing 1 changed file with 7 additions and 0 deletions.
diff --git a/p2p/subscriber.go b/p2p/subscriber.go
@@ -45,6 +45,13 @@ func WithSubscriberNetworkID(networkID string) SubscriberOption {
 	}
 }
 
+// WithSubscriberParams is a functional option that overrides SubscriberParams.
+func WithSubscriberParams(params SubscriberParams) SubscriberOption {
+	return func(p *SubscriberParams) {
+		*p = params
+	}
+}
+
 // NewSubscriber returns a Subscriber that manages the header Module's
 // relationship with the "header-sub" gossipsub topic.
 func NewSubscriber[H header.Header[H]](