Versions in this module Expand all Collapse all v2 v2.0.1 Oct 5, 2021 Changes in this version + type Feed struct + func (f *Feed) Send(value interface{}) (nsent int) + func (f *Feed) Subscribe(channel interface{}) Subscription + type ResubscribeFunc func(context.Context) (Subscription, error) + type Subscription interface + Err func() <-chan error + Unsubscribe func() + func NewSubscription(producer func(<-chan struct{}) error) Subscription + func Resubscribe(backoffMax time.Duration, fn ResubscribeFunc) Subscription + type SubscriptionScope struct + func (sc *SubscriptionScope) Close() + func (sc *SubscriptionScope) Count() int + func (sc *SubscriptionScope) Track(s Subscription) Subscription Other modules containing this package github.com/prysmaticlabs/prysm/v3 github.com/prysmaticlabs/prysm/v4 github.com/prysmaticlabs/prysm/v5
Go to main page