Fix receiver name

k-yomo · Apr 5, 2021 · fb0c35b · fb0c35b
1 parent 6a5de29
commit fb0c35b
Show file tree

Hide file tree

Showing 2 changed files with 10 additions and 10 deletions.
diff --git a/publisher_option.go b/publisher_option.go
@@ -9,19 +9,19 @@ type publisherOptionFunc struct {
  f func(config *PublisherConfig)
 }
 
-func (fdo *publisherOptionFunc) apply(do *PublisherConfig) {
- fdo.f(do)
+func (p *publisherOptionFunc) apply(pc *PublisherConfig) {
+ p.f(pc)
 }
 
-func newPublisherOptionFunc(f func(c *PublisherConfig)) *publisherOptionFunc {
+func newPublisherOptionFunc(f func(pc *PublisherConfig)) *publisherOptionFunc {
  return &publisherOptionFunc{
  f: f,
  }
 }
 
 // WithPublishInterceptor sets publish interceptors.
 func WithPublishInterceptor(interceptors ...PublishInterceptor) PublisherOption {
- return newPublisherOptionFunc(func(o *PublisherConfig) {
- o.publishInterceptors = interceptors
+ return newPublisherOptionFunc(func(sc *PublisherConfig) {
+ sc.publishInterceptors = interceptors
  })
 }
diff --git a/subscriber_option.go b/subscriber_option.go
@@ -9,19 +9,19 @@ type subscriberOptionFunc struct {
  f func(config *SubscriberConfig)
 }
 
-func (fdo *subscriberOptionFunc) apply(do *SubscriberConfig) {
- fdo.f(do)
+func (s *subscriberOptionFunc) apply(sc *SubscriberConfig) {
+ s.f(sc)
 }
 
-func newSubscriberOptionFunc(f func(c *SubscriberConfig)) *subscriberOptionFunc {
+func newSubscriberOptionFunc(f func(sc *SubscriberConfig)) *subscriberOptionFunc {
  return &subscriberOptionFunc{
  f: f,
  }
 }
 
 // WithSubscriptionInterceptor sets subscription interceptors.
 func WithSubscriptionInterceptor(interceptors ...SubscriptionInterceptor) SubscriberOption {
- return newSubscriberOptionFunc(func(o *SubscriberConfig) {
- o.subscriptionInterceptors = interceptors
+ return newSubscriberOptionFunc(func(sc *SubscriberConfig) {
+ sc.subscriptionInterceptors = interceptors
  })
 }