complexbroadcaster

Documentation

Index

• type Broadcaster
  • func NewBroadcaster() Broadcaster
  • func (b Broadcaster) Broadcast(v interface{})
  • func (b Broadcaster) Listen() Receiver
• type Receiver
  • func (r *Receiver) Read() interface{}

Types

type Broadcaster

type Broadcaster struct {
	// private fields:
	Listenc chan chan (chan broadcast)
	Sendc   chan<- interface{}
}

func NewBroadcaster

func NewBroadcaster() Broadcaster

create a new broadcaster object.

func (Broadcaster) Broadcast

func (b Broadcaster) Broadcast(v interface{})

broadcast a value to all listeners.

func (Broadcaster) Listen

func (b Broadcaster) Listen() Receiver

start listening to the broadcasts.

type Receiver

type Receiver struct {
	// private fields:
	C chan broadcast
}

func (*Receiver) Read

func (r *Receiver) Read() interface{}

read a value that has been broadcast, waiting until one is available if necessary.