channel only needs to be able to read

gopcua · Jan 19, 2022 · 8a06ec5 · 8a06ec5
1 parent 1743aa2
commit 8a06ec5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/client_sub.go b/client_sub.go
@@ -16,7 +16,7 @@ import (
 // Subscribe creates a Subscription with given parameters.
 // Parameters that have not been set are set to their default values.
 // See opcua.DefaultSubscription* constants
-func (c *Client) Subscribe(params *SubscriptionParameters, notifyCh chan *PublishNotificationData) (*Subscription, error) {
+func (c *Client) Subscribe(params *SubscriptionParameters, notifyCh chan<- *PublishNotificationData) (*Subscription, error) {
 	stats.Client().Add("Subscribe", 1)
 
 	if params == nil {

diff --git a/subscription.go b/subscription.go
@@ -29,7 +29,7 @@ type Subscription struct {
 	RevisedPublishingInterval time.Duration
 	RevisedLifetimeCount      uint32
 	RevisedMaxKeepAliveCount  uint32
-	Notifs                    chan *PublishNotificationData
+	Notifs                    chan<- *PublishNotificationData
 	params                    *SubscriptionParameters
 	items                     map[uint32]*monitoredItem
 	itemsMu                   sync.Mutex