fmesh results extraction example

results_extraction.go

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),
		)
	

	// Run
	_, err := numbersCruncher.Run()
	if err != nil {
		fmt.Println("FMesh finished with error:", err)
		os.Exit(1)
	}
	
	// Extract results
	results := numbersCruncher.ComponentByName("last-stage").OutputByName("res").Signals()

	fmt.Println("FMesh finished successfully")
	fmt.Println("Results:")
	results.ForEach(func(sig *signal.Signal) error {
		fmt.Println(sig.PayloadOrDefault("no payload"))
		return nil
	})
}