Function streamJSONLFile

cmd/importcmd.go:144–159

(path string, fn func(db.DLLMatch))

}

func streamJSONLFile(path string, fn func(db.DLLMatch)) error {
	f, err := os.Open(path)
	if err != nil {
		return err
	}
	defer f.Close()
	dec := json.NewDecoder(f)
	for dec.More() {
		var e db.DLLMatch
		if err := dec.Decode(&e); err != nil {
			break
		}
		fn(e)
	}
	return nil
}