docs: update

mgtv-tech · May 20, 2024 · 0663d04 · 0663d04
1 parent b0a134e
commit 0663d04
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 10 deletions.
diff --git a/README.md b/README.md
@@ -196,12 +196,9 @@ func Example_syncLocalUsage() {
 
 	go func() {
 		for {
-			msg, err := pubSub.ReceiveMessage(context.Background())
-			if err != nil {
-				panic(err)
-			}
+			msg := <-pubSub.Channel()
 			var event *cache.Event
-			if err = json.Unmarshal([]byte(msg.Payload), &event); err != nil {
+			if err := json.Unmarshal([]byte(msg.Payload), &event); err != nil {
 				panic(err)
 			}
 			fmt.Println(event.Keys)

diff --git a/README_en.md b/README_en.md
@@ -197,12 +197,9 @@ func Example_syncLocalUsage() {
 
 	go func() {
 		for {
-			msg, err := pubSub.ReceiveMessage(context.Background())
-			if err != nil {
-				panic(err)
-			}
+			msg := <-pubSub.Channel()
 			var event *cache.Event
-			if err = json.Unmarshal([]byte(msg.Payload), &event); err != nil {
+			if err := json.Unmarshal([]byte(msg.Payload), &event); err != nil {
 				panic(err)
 			}
 			fmt.Println(event.Keys)