pubsub

Documentation

Index

• Constants
• type PubSub
  • func New(capacity ...int) *PubSub
  • func (ps *PubSub) Pub(events ...event.Event)
  • func (ps *PubSub) Shutdown()
  • func (ps *PubSub) Sub(typ ...event.Type) chan interface{}
  • func (ps *PubSub) Unsub(ch chan interface{})

Constants

const DefaultCapacity = 1

DefaultCapacity for the Pubsub

Types

type PubSub

type PubSub struct {
	// contains filtered or unexported fields
}

func New

func New(capacity ...int) *PubSub

New Pubsub with capacity size. If capacity is not given, use default insteadly.

func (*PubSub) Pub

func (ps *PubSub) Pub(events ...event.Event)

publish Event to corresponding subscribers.

func (*PubSub) Shutdown

func (ps *PubSub) Shutdown()

func (*PubSub) Sub

func (ps *PubSub) Sub(typ ...event.Type) chan interface{}

subscribes specified EventType and return message channel.

func (*PubSub) Unsub

func (ps *PubSub) Unsub(ch chan interface{})

unsubscribes specified channel which is gotten by previous Sub().