broadcast

Documentation

Overview

Package broadcast package that provides an abstraction to broadcast values to multiple goroutines

Index

• type Broadcaster
  • func NewBroadcaster() *Broadcaster
  • func (b *Broadcaster) Broadcast(value interface{})
  • func (b *Broadcaster) Register() chan interface{}
  • func (b *Broadcaster) Unregister(ch chan interface{})

Types

type Broadcaster

type Broadcaster struct {
	// contains filtered or unexported fields
}

func NewBroadcaster

func NewBroadcaster() *Broadcaster

func (*Broadcaster) Broadcast

func (b *Broadcaster) Broadcast(value interface{})

func (*Broadcaster) Register

func (b *Broadcaster) Register() chan interface{}

func (*Broadcaster) Unregister

func (b *Broadcaster) Unregister(ch chan interface{})