mirror/go-patterns
1
0
Fork 0
mirror of https://github.com/tmrts/go-patterns.git synced 2024-11-21 20:46:08 +03:00
Code Issues Projects Releases Wiki Activity

Nothing special on Subscription (#5)

Browse Source
This commit is contained in:
Gerasimos Maropoulos 2016-09-05 17:34:47 +03:00 committed by Tamer Tas
parent 3d2d78a8a2
commit 3da8fc4d4f
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
messaging/publish_subscribe.md
View File

@ -27,11 +27,11 @@ type Subscription struct {
} }
func (s *Subscription) Publish(msg Message) error { func (s *Subscription) Publish(msg Message) error {
if _, ok := ch; !ok { if _, ok := s.ch; !ok {
return errors.New("Topic has been closed") return errors.New("Topic has been closed")
} }
ch <- msg s.ch <- msg
return nil return nil
} }