blob: b45522af9da1067bc6a0d455ee3a0bec6bb38436 (
plain) (
blame)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
|
package services
import (
"bufio"
"log"
"os/exec"
)
func Ram(path string, parameter string) <-chan string {
outChan := make(chan string)
if parameter != "frequency" {
cmd := exec.Command(path, parameter)
stdout, err := cmd.StdoutPipe()
if err != nil {
log.Fatal(err)
}
if err := cmd.Start(); err != nil {
log.Fatal(err)
}
scanner := bufio.NewScanner(stdout)
go func() {
defer close(outChan)
for scanner.Scan() {
outChan <- scanner.Text()
}
if err := scanner.Err(); err != nil {
log.Printf("scanner error %v\n", err)
}
}()
}
return outChan
}
|
