Dummy string processing program using GoFlow and Blow https://github.com/trustmaster/goflow https://github.com/samuell/blow

fbp8.go

package main

import (
	"github.com/samuell/blow"
	"github.com/trustmaster/goflow"
)

const (
	BUFSIZE    = 512
)

// ---------------------------------------------------------
// BaseComplementer network
// ---------------------------------------------------------
type BaseComplementerApp struct {
	flow.Graph
}

func NewBaseCompelenterApp() *BaseComplementerApp {
	// Make all processes started from here synchronous
	flow.DefaultComponentMode = flow.ComponentModeSync

	network := new(BaseComplementerApp)
	network.InitGraphState()

	// Add components
	network.Add(new(blow.FileReader), "filereader")
	network.Add(new(blow.BaseComplementer), "bc1")
	network.Add(new(blow.BaseComplementer), "bc2")
	network.Add(new(blow.BaseComplementer), "bc3")
	network.Add(new(blow.BaseComplementer), "bc4")
	network.Add(new(blow.BaseComplementer), "bc5")
	network.Add(new(blow.BaseComplementer), "bc6")
	network.Add(new(blow.BaseComplementer), "bc7")
	network.Add(new(blow.BaseComplementer), "bc8")
	network.Add(new(blow.Printer), "printer")

	// Connect components
	network.MapInPort("In", "filereader", "FileName")
	network.Connect("filereader", "Line", "bc1", "Sequence")
	network.Connect("bc1", "BaseComplementedSequence", "bc2", "Sequence")
	network.Connect("bc2", "BaseComplementedSequence", "bc3", "Sequence")
	network.Connect("bc3", "BaseComplementedSequence", "bc4", "Sequence")
	network.Connect("bc4", "BaseComplementedSequence", "bc5", "Sequence")
	network.Connect("bc5", "BaseComplementedSequence", "bc6", "Sequence")
	network.Connect("bc6", "BaseComplementedSequence", "bc7", "Sequence")
	network.Connect("bc7", "BaseComplementedSequence", "bc8", "Sequence")
	network.Connect("bc8", "BaseComplementedSequence", "printer", "Line")

	return network
}

// ---------------------------------------------------------
// Main method
// ---------------------------------------------------------
var finish chan bool

// Use this handler to let main() know when the network terminates
func (a *BaseComplementerApp) Finish() {
	finish <- true
}

func main() {
	// Termination signal channel
	finish = make(chan bool)
	// Create network
	net := NewBaseCompelenterApp()

	// Create the "In" channel
	in := make(chan string)
	net.SetInPort("In", in)

	// Run net
	flow.RunNet(net)

	// Give the Filename to read
	in <- "homosapiens_chrom_y.fa"

	close(in)
	<-finish
}