mirror/go-patterns
1
0
Fork 0
mirror of https://github.com/tmrts/go-patterns.git synced 2025-04-03 13:13:34 +03:00
Code Issues Projects Releases Wiki Activity

Nothing special on Subscription

Browse source
This commit is contained in:
Gerasimos Maropoulos 2016-09-05 06:56:23 +03:00 • committed by GitHub
parent 3d2d78a8a2
commit 655d3daf67
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 {
if _, ok := ch; !ok {
if _, ok := s.ch; !ok {
return errors.New("Topic has been closed")
}
ch <- msg
s.ch <- msg
return nil
}