1
0
mirror of https://github.com/chai2010/advanced-go-programming-book.git synced 2025-05-24 12:32:21 +00:00
This commit is contained in:
sfw 2018-08-06 23:59:04 +08:00
parent cb90c19989
commit 5e72024153

View File

@ -315,9 +315,9 @@ func (p *PubsubService) Publish(
func (p *PubsubService) Subscribe( func (p *PubsubService) Subscribe(
arg *String, stream PubsubService_SubscribeServer, arg *String, stream PubsubService_SubscribeServer,
) error { ) error {
ch := p.Subscribe(func(v interface{}) bool { ch := p.pub.SubscribeTopic(func(v interface{}) bool {
if key, ok := v.(string); ok { if key, ok := v.(string); ok {
if strings.Hasprefix(arg.GetValue()) { if strings.HasPrefix(key,arg.GetValue()) {
return true return true
} }
} }