merger

Documentation

Index

• func Joiner(metadata, setIDs <-chan *line, out chan<- *line)
• func Reader(fname string, out chan<- *line)

Functions

func Joiner

func Joiner(metadata, setIDs <-chan *line, out chan<- *line)

func Reader

func Reader(fname string, out chan<- *line)

func Merge(metadata string, branded string) {
	// read metadata
	metadataChan := make(chan *line)
	go reader(metadata, metadataChan)

	// read strength set IDs
	brandedChan := make(chan *line)
	go reader(branded, brandedChan)

	// join the two data streams
	mergedLinesChan := make(chan *line)
	go joiner(metadataChan, brandedChan, mergedLinesChan)

	for l := range mergedLinesChan {
		fmt.Printf("%v,%v\n", l.id, l.restOfLine)
	}
}