Revision indexing in progress... (symbol navigation in revisions will be accurate after indexed)
-
| skipped 1 lines |
2 | 2 | | |
3 | 3 | | import ( |
4 | 4 | | "bufio" |
| 5 | + | "fmt" |
5 | 6 | | "net/http" |
6 | 7 | | "os" |
7 | 8 | | "sync" |
| skipped 26 lines |
34 | 35 | | |
35 | 36 | | func (r *Runner) Run() { |
36 | 37 | | r.InWg.Add(1) |
37 | | - | go pushInput(r) |
38 | 38 | | |
| 39 | + | go pushInput(r) |
39 | 40 | | r.InWg.Add(1) |
40 | | - | go execute(r) |
41 | 41 | | |
| 42 | + | go execute(r) |
42 | 43 | | r.OutWg.Add(1) |
| 44 | + | |
43 | 45 | | go pullOutput(r) |
44 | | - | |
45 | 46 | | r.InWg.Wait() |
46 | 47 | | |
47 | 48 | | close(r.Output) |
| skipped 54 lines |
102 | 103 | | options.Output = file |
103 | 104 | | } |
104 | 105 | | |
105 | | - | //print output |
106 | | - | //write output to file |
| 106 | + | // write output to file |
| 107 | + | |
| 108 | + | fmt.Println(out) |
107 | 109 | | } |
108 | 110 | | |