logos-messaging/go-libp2p-pubsub
1
0
Fork 0
mirror of https://github.com/logos-messaging/go-libp2p-pubsub.git synced 2026-01-02 21:03:07 +00:00
Code Issues Packages Projects Releases Wiki Activity

minor variable refactor

Browse Source
This commit is contained in:
Adin Schmahmann 2019-10-18 03:25:24 -04:00 committed by GitHub
parent d28f450046
commit c0494a42f4
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pubsub.go
View File

@ -736,11 +736,11 @@ func (p *PubSub) GetTopics() []string {
// Publish publishes data to the given topic.
func (p *PubSub) Publish(topic string, data []byte) error {
seqno := p.nextSeqno()
hostID := p.host.ID()
id := p.host.ID()
m := &pb.Message{
Data: data,
TopicIDs: []string{topic},
From: []byte(hostID),
From: []byte(id),
Seqno: seqno,
}
if p.signKey != nil {
@ -750,7 +750,7 @@ func (p *PubSub) Publish(topic string, data []byte) error {
return err
}
}
p.publish <- &Message{m, hostID}
p.publish <- &Message{m, id}
return nil
}