From fb0c35b48e0878b7274178b2273fb19877df2efc Mon Sep 17 00:00:00 2001 From: k-yomo Date: Mon, 5 Apr 2021 18:26:35 +0900 Subject: [PATCH] Fix receiver name --- publisher_option.go | 10 +++++----- subscriber_option.go | 10 +++++----- 2 files changed, 10 insertions(+), 10 deletions(-) diff --git a/publisher_option.go b/publisher_option.go index 1f930e6..5753d33 100644 --- a/publisher_option.go +++ b/publisher_option.go @@ -9,11 +9,11 @@ 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, } @@ -21,7 +21,7 @@ func newPublisherOptionFunc(f func(c *PublisherConfig)) *publisherOptionFunc { // 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 index a31d8b4..1dbefea 100644 --- a/subscriber_option.go +++ b/subscriber_option.go @@ -9,11 +9,11 @@ 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, } @@ -21,7 +21,7 @@ func newSubscriberOptionFunc(f func(c *SubscriberConfig)) *subscriberOptionFunc // 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 }) }