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

feat: detach WithMsgIdFunction

Browse Source
This commit is contained in:
Wondertan 2022-01-22 14:00:57 +02:00 committed by vyzo
parent f9b2412210
commit fcbbfd8131
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
pubsub.go
View File

@ -20,7 +20,7 @@ import (
"github.com/libp2p/go-libp2p-core/protocol"
logging "github.com/ipfs/go-log"
timecache "github.com/whyrusleeping/timecache"
"github.com/whyrusleeping/timecache"
)
// DefaultMaximumMessageSize is 1mb.
@ -1161,7 +1161,7 @@ type TopicOptions struct{}
type TopicOpt func(t *Topic) error
// WithMsgIdFunction sets custom MsgIdFunction for a Topic, enabling topics to have own msg id generation rules.
func (p *PubSub) WithMsgIdFunction(msgId MsgIdFunction) TopicOpt {
func WithMsgIdFunction(msgId MsgIdFunction) TopicOpt {
return func(t *Topic) error {
t.p.idGen.Set(t.topic, msgId)
return nil