pubchannel

Documentation

Index

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

Types

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

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