reverse

Documentation

Overview

Package reverse provide a limited variant of pubsub where the subscriber creates the listener and the publisher connects. Used when the publisher is not a long-running agent, and there is only one subscriber.

Package reverse provide a limited variant of pubsub where the subscriber creates the listener and the publisher connects. Used when the publisher is not a long-running agent, and there is only one subscriber.

Index

• func NewSubscriber(log *base.LogObject, agent string, topic interface{}) <-chan string
• func Publish(log *base.LogObject, agent string, data interface{}) error

Functions

func NewSubscriber

func NewSubscriber(log *base.LogObject, agent string, topic interface{}) <-chan string

NewSubscriber creates a goroutine which will send strings to the channel Returns the channel to the caller XXX return chan?

func Publish

func Publish(log *base.LogObject, agent string, data interface{}) error

Publish publishes data to