multiplexer
import "command-line-arguments"Index
type Multiplexer (opens in a new tab)
A Multiplexer is the structure that implements sub/unsub to pipe data between channels.
type Multiplexer struct {
// contains filtered or unexported fields
}func NewMultiplexer (opens in a new tab)
func NewMultiplexer() *Multiplexerfunc (*Multiplexer) Publish (opens in a new tab)
func (m *Multiplexer) Publish(msg interface{})func (*Multiplexer) Start (opens in a new tab)
func (m *Multiplexer) Start()func (*Multiplexer) Stop (opens in a new tab)
func (m *Multiplexer) Stop()func (*Multiplexer) Subscribe (opens in a new tab)
func (m *Multiplexer) Subscribe() chan interface{}func (*Multiplexer) Unsubscribe (opens in a new tab)
func (m *Multiplexer) Unsubscribe(msgChannel chan interface{})Generated by gomarkdoc (opens in a new tab)