rename OnChange to OnMessage

Co-authored-by: Easwar Swaminathan <[email protected]>
grpc · arvindbr8 · Jun 30, 2023 · Apr 1, 2023 · Apr 3, 2023 · Apr 4, 2023
commit b6f28434519c360757b5f3396abd776c89d4e5f4
diff --git a/internal/grpcsync/pubsub.go b/internal/grpcsync/pubsub.go
@@ -23,12  23,11 @@ import (
 	"sync"
 )
 
-// Watcher wraps the functionality to be implemented by components
-// interested in watching msg changes.
-type Watcher interface {
-	// OnChange is invoked to report msg changes on the
-	// entity being watched.
-	OnChange(msg interface{})
 // Subscriber represents an entity that is subscribed to messages published on a PubSub.
 // It wraps the callback to be invoked by the PubSub when a new message is published.
 type Subscriber interface {
 	// OnMessage is invoked to when a new message is published.
 	OnMessage(msg interface{})
 }
 
 // PubSub is a simple one-to-many publish-subscribe system that supports messages