status-im/go-libp2p-pubsub
2
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Define a public error ErrSubscriptionCancelled.

Browse Source
This commit is contained in:
Preston Van Loon 2020-07-06 10:58:44 -07:00 committed by vyzo
parent 8945f91465
commit 54f20b5a2a
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
pubsub.go
View File

@ -28,6 +28,10 @@ const DefaultMaxMessageSize = 1 << 20
var ( var (
TimeCacheDuration = 120 * time.Second TimeCacheDuration = 120 * time.Second
// ErrSubscriptionCancelled may be returned when a subscription Next() is called after the
// subscription has been cancelled.
ErrSubscriptionCancelled = errors.New("subscription cancelled by calling sub.Cancel()")
) )
var log = logging.Logger("pubsub") var log = logging.Logger("pubsub")
@ -629,7 +633,7 @@ func (p *PubSub) handleRemoveSubscription(sub *Subscription) {
return return
} }
sub.err = fmt.Errorf("subscription cancelled by calling sub.Cancel()") sub.err = ErrSubscriptionCancelled
sub.close() sub.close()
delete(subs, sub) delete(subs, sub)