counter

README

Flow-based programming and concurrency

This is an example of a FBP flow using only go channels and pipelines. It counts the words and letters in sentences

Documentation

Index

• func Joiner(channels ...<-chan fmt.Stringer) <-chan fmt.Stringer
• func LetterCounter(sentences <-chan string) <-chan fmt.Stringer
• func Printer(values <-chan fmt.Stringer) <-chan struct{}
• func Spliter(sentences <-chan string) (<-chan string, <-chan string)
• func WordCounter(sentences <-chan string) <-chan fmt.Stringer
• type Letters
  • func (l Letters) String() string
• type Words
  • func (w Words) String() string

Functions

func Joiner

func Joiner(channels ...<-chan fmt.Stringer) <-chan fmt.Stringer

Joiner joins two or more Stringer channels into a single Stringer channel

func LetterCounter

func LetterCounter(sentences <-chan string) <-chan fmt.Stringer

LetterCounter is a process that counts letters in a string

func Printer

func Printer(values <-chan fmt.Stringer) <-chan struct{}

Printer prints the values sent to it

func Spliter

func Spliter(sentences <-chan string) (<-chan string, <-chan string)

Spliter copies a string to two channels

func WordCounter

func WordCounter(sentences <-chan string) <-chan fmt.Stringer

WordCounter is a step that counts the words in a string

Types

type Letters

type Letters struct {
	Count int
}

Letter represents a letter count

func (Letters) String

func (l Letters) String() string

type Words

type Words struct {
	Count int
}

Words represents a word count

func (Words) String

func (w Words) String() string