pubchannel

type PubChannel ¶

type PubChannel struct {
	Ch chan interface{}
	// contains filtered or unexported fields
}

PubChannel abstracts zmqpubsub.Publisher using Go's channels. Unlike zmqpubsub, senders can be any goroutine.

func New(key string, stopCh chan bool) *PubChannel