fix ch4-04-3

chai2010 · Aug 18, 2018 · 2305589 · 2305589
1 parent 72f72eb
commit 2305589
Showing 1 changed file with 9 additions and 3 deletions.
diff --git a/ch4-rpc/ch4-04-grpc.md b/ch4-rpc/ch4-04-grpc.md
@@ -217,22 +217,26 @@ for {
 ```go
 import (
 	"github.com/docker/docker/pkg/pubsub"
+	"time"
+	"fmt"
+	"strings"
+	"runtime"
 )
 
 func main() {
 	p := pubsub.NewPublisher(100*time.Millisecond, 10)
 
 	golang := p.SubscribeTopic(func(v interface{}) bool {
 		if key, ok := v.(string); ok {
-			if strings.Hasprefix("golang:") {
+			if strings.HasPrefix(key,"golang:") {
 				return true
 			}
 		}
 		return false
 	})
 	docker := p.SubscribeTopic(func(v interface{}) bool {
 		if key, ok := v.(string); ok {
-			if strings.Hasprefix("docker:") {
+			if strings.HasPrefix(key,"docker:") {
 				return true
 			}
 		}
@@ -250,8 +254,10 @@ func main() {
 	go func () {
 		fmt.Println("docker topic:", <-docker)
 	} ()
+	for {
+		runtime.Gosched()
+	}
 
-	<-make(chan bool)
 }
 ```