Pass options to the s.NewSubscriber
This commit is contained in:
parent
e3f818d18e
commit
eff39083ca
@ -81,5 +81,5 @@ func RegisterHandler(s server.Server, h interface{}, opts ...server.HandlerOptio
|
|||||||
|
|
||||||
// RegisterSubscriber is syntactic sugar for registering a subscriber
|
// RegisterSubscriber is syntactic sugar for registering a subscriber
|
||||||
func RegisterSubscriber(topic string, s server.Server, h interface{}, opts ...server.SubscriberOption) error {
|
func RegisterSubscriber(topic string, s server.Server, h interface{}, opts ...server.SubscriberOption) error {
|
||||||
return s.Subscribe(s.NewSubscriber(topic, h))
|
return s.Subscribe(s.NewSubscriber(topic, h, opts...))
|
||||||
}
|
}
|
||||||
|
Loading…
Reference in New Issue
Block a user