chore: rename to NotifyReceivedChanges

Signed-off-by: Ben Meier <[email protected]>

examples/http2writer/main.go

@@ -44,7 +44,7 @@ func mainInner() error {
 			} else if _, err := doc.Commit("commit"); err != nil {
 				panic(err)
 			}
-			a.NotifyPossibleChanges()
+			a.NotifyReceivedChanges()
 		}
 	}()
 

read.go

@@ -11,10 +11,10 @@ import (
 	"github.com/automerge/automerge-go"
 )
 
-// NotifyPossibleChanges should be called after the shared doc has "received" a message. This allows any goroutines that
+// NotifyReceivedChanges should be called after the shared doc has "received" a message. This allows any goroutines that
 // are generating messages to be preempted and know that new messaged may be available. This is a broadcast because
 // any number of goroutines may be writing changes to the doc to their client.
-func (b *SharedDoc) NotifyPossibleChanges() {
+func (b *SharedDoc) NotifyReceivedChanges() {
 	b.mutex.Lock()
 	defer b.mutex.Unlock()
 	for _, channel := range b.channels {
@@ -44,7 +44,7 @@ func (b *SharedDoc) consumeMessagesFromReader(ctx context.Context, state *autome
 				received += 1
 				receivedChanges += len(m.Changes())
 				receivedBytes += len(sc.Bytes()) + 1
-				b.NotifyPossibleChanges()
+				b.NotifyReceivedChanges()
 
 				if terminationCheck(state.Doc, m) {
 					log.InfoContext(ctx, "termination check met")

read_test.go

@@ -15,7 +15,7 @@ import (
 func TestNotifyPossibleChanges_no_subs(t *testing.T) {
 	t.Parallel()
 	a := NewSharedDoc(automerge.New())
-	a.NotifyPossibleChanges()
+	a.NotifyReceivedChanges()
 }
 
 func TestNotifyPossibleChanges_with_sub(t *testing.T) {
@@ -33,7 +33,7 @@ func TestNotifyPossibleChanges_with_sub(t *testing.T) {
 	})
 
 	t.Run("message available after notify", func(t *testing.T) {
-		a.NotifyPossibleChanges()
+		a.NotifyReceivedChanges()
 
 		select {
 		case v := <-sub:
@@ -45,7 +45,7 @@ func TestNotifyPossibleChanges_with_sub(t *testing.T) {
 
 	t.Run("closer function close channel", func(t *testing.T) {
 		fin()
-		a.NotifyPossibleChanges()
+		a.NotifyReceivedChanges()
 		_, ok := <-sub
 		assertEqual(t, false, ok)
 	})