hovsep

package main

import (
	"fmt"
	"github.com/trustmaster/goflow"
)

// Greeter sends greetings
type Greeter struct {
	Name           <-chan string // input port

hovsep

func main() {
	// Build mesh
	numbersCruncher := getMesh()

	// Init with data
	numbersCruncher.ComponentByName("first-stage").InputByName("num").PutSignals(
		signal.New(1),
		signal.New(2),
		signal.New(3),
		)

hovsep

func(this *component.Component) error {
	num := this.InputByName("num").Signals().FirstPayloadOrDefault(0) // Read inputs
	this.OutputByName("res").PutSignals(signal.New(num.(int) * 3)) // Provide outputs
	return nil // Report possible errors
}