Remove unused path variables from decodeVideoStream

download.go

@@ -37,7 +37,7 @@ func fixExtension(str string) string {
 // decodeVideoStream processes downloaded video stream and
 // decodeVideoStream calls helper functions and writes the
 // output in the required format
-func decodeVideoStream(videoUrl, path, format string) error {
+func decodeVideoStream(videoUrl, format string) error {
 
 	// Get video data
 	res, err := goutubedl.New(context.Background(), videoUrl, goutubedl.Options{})

download_test.go

@@ -22,7 +22,7 @@ func TestApi(t *testing.T) {
 
 	// path := "test"
 	for i, table := range tables {
-		err := decodeVideoStream(table.url, "~/Downloads", "mp3")
+		err := decodeVideoStream(table.url, "mp3")
 		if err != nil {
 			t.Errorf("videoId(%d): expected %q, actual %q", i, table.id, err)
 		}
@@ -31,7 +31,7 @@ func TestApi(t *testing.T) {
 
 func BenchmarkVideoId(b *testing.B) {
 	for n := 0; n < b.N; n++ {
-		if err := decodeVideoStream(tables[0].url, "~/Downloads", "mp3"); err != nil {
+		if err := decodeVideoStream(tables[0].url, "mp3"); err != nil {
 			b.Errorf("Error downloading video: %v", err)
 		}
 	}

main.go

@@ -89,18 +89,18 @@ func parseUrls(urls string) []string {
 
 func beginDownload(urls []string) {
 	if len(urls) < 2 {
-		if err := decodeVideoStream(urls[0], path, format); err != nil {
+		if err := decodeVideoStream(urls[0], format); err != nil {
 			logrus.Errorf("Unable to beginDownload: %v", err)
 		}
 	} else {
-		if err := concurrentDownload(MAXDOWNLOADS, format, path, urls); err != nil {
+		if err := concurrentDownload(MAXDOWNLOADS, format, urls); err != nil {
 			logrus.Errorf("Unable to concurrently download videos: %v with errors => %v", urls, err)
 		}
 	}
 }
 
 //DownloadStreams download a batch of elements asynchronously
-func concurrentDownload(maxOperations int, format, outputPath string, urls []string) <-chan error {
+func concurrentDownload(maxOperations int, format string, urls []string) <-chan error {
 
 	var wg sync.WaitGroup
 	wg.Add(len(urls))
@@ -109,7 +109,7 @@ func concurrentDownload(maxOperations int, format, outputPath string, urls []str
 	for _, url := range urls {
 		go func(url string) {
 			defer wg.Done()
-			ch <- decodeVideoStream(url, path, format)
+			ch <- decodeVideoStream(url, format)
 		}(url)
 	}