in worker.go [101:110]
func (w *worker) start() { for worker := 0; worker < concurrency; worker++ { go func() { for m := range w.inputs { o := m.HTTP() w.outputs <- o } }() } }