chantools

Documentation

Overview

Package chantools was obtained from https://github.com/theepicsnail/goChanTools and subsequently altered for our needs.

Index

• type OneToManyChan
  • func NewOneToManyChan(srcChan <-chan string) *OneToManyChan
  • func (o *OneToManyChan) AddOutputChan(ch chan<- string)
  • func (o *OneToManyChan) RemoveOutputChan(ch chan<- string)

Types

type OneToManyChan

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

OneToManyChan can broadcase a single channel into many channels.

func NewOneToManyChan

func NewOneToManyChan(srcChan <-chan string) *OneToManyChan

NewOneToManyChan constructs a one-to-many broadcaster

func (*OneToManyChan) AddOutputChan

func (o *OneToManyChan) AddOutputChan(ch chan<- string)

AddOutputChan adds the given channel to the list of channels to broadcast to.

func (*OneToManyChan) RemoveOutputChan

func (o *OneToManyChan) RemoveOutputChan(ch chan<- string)

RemoveOutputChan removes the given channel from the list of channels to broadcast to.