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

fix some comments

Browse Source
This commit is contained in:
Michael Muré 2021-07-12 21:56:09 +02:00 committed by Adin Schmahmann
parent 50b1cfadc8
commit c02d4c7179
2 changed files with 4 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pubsub.go
View File

@ -189,12 +189,12 @@ type PubSubRouter interface {
type AcceptStatus int
const (
// AcceptAll signals to accept the incoming RPC for full processing
// AcceptNone signals to drop the incoming RPC
AcceptNone AcceptStatus = iota
// AcceptControl signals to accept the incoming RPC only for control message processing by
// the router. Included payload messages will _not_ be pushed to the validation queue.
AcceptControl
// AcceptNone signals to drop the incoming RPC
// AcceptAll signals to accept the incoming RPC for full processing
AcceptAll
)
@ -1136,7 +1136,7 @@ type addSubReq struct {
type SubOpt func(sub *Subscription) error
// Subscribe returns a new Subscription for the given topic.
// Note that subscription is not an instanteneous operation. It may take some time
// Note that subscription is not an instantaneous operation. It may take some time
// before the subscription is processed by the pubsub main loop and propagated to our peers.
//
// Deprecated: use pubsub.Join() and topic.Subscribe() instead

2
topic.go
View File

@ -130,7 +130,7 @@ func (t *Topic) sendNotification(evt PeerEvent) {
}
// Subscribe returns a new Subscription for the topic.
// Note that subscription is not an instanteneous operation. It may take some time
// Note that subscription is not an instantaneous operation. It may take some time
// before the subscription is processed by the pubsub main loop and propagated to our peers.
func (t *Topic) Subscribe(opts ...SubOpt) (*Subscription, error) {
t.mux.RLock()