subscription

Documentation

Index

• type Subscription
  • func New() *Subscription
  • func (s *Subscription) Cancel(err error)
  • func (s *Subscription) Done() <-chan struct{}
  • func (s *Subscription) Err() error
  • func (s *Subscription) Unsubscribe()

Types

type Subscription

type Subscription struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func New

func New() *Subscription

func (*Subscription) Cancel

func (s *Subscription) Cancel(err error)

func (*Subscription) Done

func (s *Subscription) Done() <-chan struct{}

func (*Subscription) Err

func (s *Subscription) Err() error

func (*Subscription) Unsubscribe

func (s *Subscription) Unsubscribe()