publisher

Documentation

Index

• type ObservableType
• type PubSub
  • func NewPubSub() PubSub
• type Publisher
• type Subscriber

Types

type ObservableType

type ObservableType generic.Type // nolint

type PubSub

type PubSub interface {
	Publisher
	Subscriber
}

PubSub -

func NewPubSub

func NewPubSub() PubSub

NewPubSub constructs and returns a new PubSub

type Publisher

type Publisher interface {
	Publish(ObservableType)
}

Publisher deals with the publishing part of our PubSub

type Subscriber

type Subscriber interface {
	Subscribe(chan ObservableType, ...filter)
	Unsubscribe(chan ObservableType)
}

Subscriber deals with the subscribing part of our PubSub