1
0
mirror of https://github.com/ipfs/kubo.git synced 2025-07-02 20:32:58 +08:00

Revert "hotfix(dep) duplicates TEMP DONT MERGE TO MASTER"

This reverts commit 49004e9743110ba69c07852c3a105dac2e01e1c4.
This commit is contained in:
Brian Tiger Chow
2014-11-21 18:23:47 -08:00
committed by Jeromy
parent 044db5bee8
commit e393edcc28

View File

@ -66,14 +66,6 @@ func (ps *PubSub) AddSub(ch chan interface{}, topics ...string) {
ps.cmdChan <- cmd{op: sub, topics: topics, ch: ch}
}
// AddSubOnce adds one-time subscriptions to an existing channel.
// For each topic, a message will be sent once.
func (ps *PubSub) AddSubOnce(ch chan interface{}, topics ...string) {
for _, t := range topics {
ps.cmdChan <- cmd{op: subOnce, topics: []string{t}, ch: ch}
}
}
// Pub publishes the given message to all subscribers of
// the specified topics.
func (ps *PubSub) Pub(msg interface{}, topics ...string) {