From 2305589cd72f2e781ad0f8d9482ccabd12d76eca Mon Sep 17 00:00:00 2001 From: alpha Date: Sun, 19 Aug 2018 07:29:56 +0800 Subject: [PATCH] fix ch4-04-3 --- ch4-rpc/ch4-04-grpc.md | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/ch4-rpc/ch4-04-grpc.md b/ch4-rpc/ch4-04-grpc.md index f8e8604..20489f5 100644 --- a/ch4-rpc/ch4-04-grpc.md +++ b/ch4-rpc/ch4-04-grpc.md @@ -217,6 +217,10 @@ for { ```go import ( "github.com/docker/docker/pkg/pubsub" + "time" + "fmt" + "strings" + "runtime" ) func main() { @@ -224,7 +228,7 @@ func main() { golang := p.SubscribeTopic(func(v interface{}) bool { if key, ok := v.(string); ok { - if strings.Hasprefix("golang:") { + if strings.HasPrefix(key,"golang:") { return true } } @@ -232,7 +236,7 @@ func main() { }) 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) } ```