Merge pull request #10 from mgtv-tech/feat_synclocal

perf examples
mgtv-tech · May 20, 2024 · 90a18b0 · 90a18b0
2 parents f623c4d + 0663d04
commit 90a18b0
Show file tree

Hide file tree

Showing 3 changed files with 6 additions and 15 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)

diff --git a/example_cache_test.go b/example_cache_test.go
@@ -161,12 +161,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)