package
0.3.0
Repository: https://github.com/netobserv/gopipes.git
Documentation: pkg.go.dev

# Functions

EvenFilter is a middle node that reads the numbers from the input channel and only forwards those that are Even.
Messager is a middle node that forwards each string received from the input channel, prepending the given message.
OddFilter is a Middle Node that reads the numbers from the input channel and only forwards those that are Odd.
Printer is a Terminal Node that just prints each string received by its input channel.
StartCounter is a Start Node that generates some ordered numbers each 100 milliseconds.
StartRandoms is a Start Node that generates some random numbers each 150 milliseconds.