Versions in this module Expand all Collapse all v1 v1.1.4 Dec 12, 2015 Changes in this version + func New() internal.PubsubWithContext + type Pubsub struct + func (this *Pubsub) Publish(context app.Context, topic string, message app.PubsubMessage) + func (this *Pubsub) Subscribe(context app.Context, topic string, handler app.TopicHandler) + type TopicHandlerList struct + func NewTopicHandlerList(handlers ...app.TopicHandler) *TopicHandlerList + func (this *TopicHandlerList) Add(handler app.TopicHandler) + func (this *TopicHandlerList) Dispatch(message app.PubsubMessage)
Go to main page