(upd mess.Update)
| 83 | } |
| 84 | |
| 85 | func (p *PubSubPipe) Push(upd mess.Update) error { |
| 86 | psKey, err := p.channel(upd.Key) |
| 87 | if err != nil { |
| 88 | return err |
| 89 | } |
| 90 | |
| 91 | updBlob, err := formatUpdate(p.myID(), upd) |
| 92 | if err != nil { |
| 93 | return err |
| 94 | } |
| 95 | |
| 96 | return p.PubSub.Publish(psKey, updBlob) |
| 97 | } |
| 98 | |
| 99 | func (p *PubSubPipe) Close() error { |
| 100 | return p.PubSub.Close() |
nothing calls this directly
no test coverage detected