pipe_exec_to_channel.go

package main

import (
	"bufio"
	"fmt"
	"io"
	"log"
	"os/exec"
	"strings"
)

func cmdChan(bin string, args ...string) (<-chan string, error) {
	c := make(chan string)
	pr, pw := io.Pipe()
	defer pw.Close()
	cmd := exec.Command(bin, args...)
	cmd.Stdout = pw
	go func() {
		defer pr.Close()
		defer close(c) // sender must close the channel
		rd := bufio.NewReader(pr)
		for {
			line, err := rd.ReadString('\n')
			if err != nil {
				return
			}
			line = strings.TrimRight(line, "\n")
			if line != "" {
				c <- line
			}
		}

	}()
	if err := cmd.Run(); err != nil {
		return nil, err
	}
	return c, nil
}

func main() {
	c, err := cmdChan("ls", "-alh")
	if err != nil {
		log.Fatalln("make line chan failed:", err)
	}
	for line := range c {
		fmt.Println(line)
	}

}