pubsub

Documentation

Index

• type ObjectType
• type PubSubName
• type PubSubNameFilter
• type PubSubNamePubSub
  • func NewPubSubNamePubSub() PubSubNamePubSub
• type PubSubNameSubscription

Types

type ObjectType

type ObjectType generic.Type // nolint

type PubSubName

type PubSubName string // nolint

type PubSubNameFilter

type PubSubNameFilter func(ObjectType) bool

type PubSubNamePubSub

type PubSubNamePubSub interface {
	Publish(ObjectType)
	Subscribe(...PubSubNameFilter) PubSubNameSubscription
}

PubSubNamePubSub -

func NewPubSubNamePubSub

func NewPubSubNamePubSub() PubSubNamePubSub

NewPubSubName constructs and returns a new PubSubNamePubSub

type PubSubNameSubscription

type PubSubNameSubscription interface {
	Next() (ObjectType, error)
	Cancel()
}

PubSubNameSubscription is returned for every subscription