# multiplexer

import "command-line-arguments"

# Index

  • type Multiplexer
    • func NewMultiplexer() *Multiplexer
    • func (m *Multiplexer) Publish(msg interface)
    • func (m *Multiplexer) Start()
    • func (m *Multiplexer) Stop()
    • func (m *Multiplexer) Subscribe() chan interface
    • func (m *Multiplexer) Unsubscribe(msgChannel chan interface)

# type Multiplexer

A Multiplexer is the structure that implements sub/unsub to pipe data between channels.

type Multiplexer struct {
    // contains filtered or unexported fields

# func NewMultiplexer

func NewMultiplexer() *Multiplexer

# func (*Multiplexer) Publish

func (m *Multiplexer) Publish(msg interface{})

# func (*Multiplexer) Start

func (m *Multiplexer) Start()

# func (*Multiplexer) Stop

func (m *Multiplexer) Stop()

# func (*Multiplexer) Subscribe

func (m *Multiplexer) Subscribe() chan interface{}

# func (*Multiplexer) Unsubscribe

func (m *Multiplexer) Unsubscribe(msgChannel chan interface{})

Generated by gomarkdoc