pubsub

Documentation

Index

• Constants
• type Filter
• type PubSub
  • func New() PubSub
• type Publisher
• type Subscriber
• type Subscription

Constants

const (
	ErrSubscriptionCanceled = errors.Error("subscription canceled")
)

Types

type Filter

type Filter func(interface{}) bool

type PubSub

type PubSub interface {
	Publisher
	Subscriber
}

func New

func New() PubSub

New constructs and returns a new PubSub

type Publisher

type Publisher interface {
	Publish(interface{})
}

Publisher deals with the publishing part of our PubSub

type Subscriber

type Subscriber interface {
	Subscribe(...Filter) Subscription
}

Subscriber deals with the subscribing part of our PubSub

type Subscription

type Subscription interface {
	Next() (interface{}, error)
	Cancel()
}

Subscription is returned for every subscription