pubsub

Documentation

Index

• type PubSub
  • func Initialize(capacity int) *PubSub
  • func (ps *PubSub) Publish(topic string, message interface{})
  • func (ps *PubSub) Subscribe(topic string) chan interface{}

Types

type PubSub

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

func Initialize

func Initialize(capacity int) *PubSub

func (*PubSub) Publish

func (ps *PubSub) Publish(topic string, message interface{})

* Note This will block the producer if any consumer hits the capacity depth

func (*PubSub) Subscribe

func (ps *PubSub) Subscribe(topic string) chan interface{}

* This is not thread safe, so set up all the subscribers in the main thread