Channel: Distributing tasks to Goroutines example

processor.go

type StreamProcessor struct {}
func (sp *StreamProcessor) Consume(fn func(r *Record) error) {
    for {
        records, _ := sp.GetRecords() // error is not handled for simplicity purpose
        for _, r := range records {
            go handleRecord(fn, r) // distributing task across goroutines. the output channel is not included for simplicity purpose
        }
    }
}