book/advanced-go-programming-book
1
0
Fork 0
mirror of https://github.com/chai2010/advanced-go-programming-book.git synced 2025-05-24 04:22:22 +00:00
Code Issues Releases Wiki Activity

fix ch4-04-3

Browse Source
This commit is contained in:
alpha 2018-08-19 07:29:56 +08:00
parent 72f72eb97a
commit 2305589cd7
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
ch4-rpc/ch4-04-grpc.md
View File

@ -217,6 +217,10 @@ for {
```go ```go
import ( import (
"github.com/docker/docker/pkg/pubsub" "github.com/docker/docker/pkg/pubsub"
"time"
"fmt"
"strings"
"runtime"
) )
func main() { func main() {
@ -224,7 +228,7 @@ func main() {
golang := p.SubscribeTopic(func(v interface{}) bool { golang := p.SubscribeTopic(func(v interface{}) bool {
if key, ok := v.(string); ok { if key, ok := v.(string); ok {
if strings.Hasprefix("golang:") { if strings.HasPrefix(key,"golang:") {
return true return true
} }
} }
@ -232,7 +236,7 @@ func main() {
}) })
docker := p.SubscribeTopic(func(v interface{}) bool { docker := p.SubscribeTopic(func(v interface{}) bool {
if key, ok := v.(string); ok { if key, ok := v.(string); ok {
if strings.Hasprefix("docker:") { if strings.HasPrefix(key,"docker:") {
return true return true
} }
} }
@ -250,8 +254,10 @@ func main() {
go func () { go func () {
fmt.Println("docker topic:", <-docker) fmt.Println("docker topic:", <-docker)
} () } ()
for {
runtime.Gosched()
}
<-make(chan bool)
} }
``` ```