| 1 |
package gcss |
| 2 |
|
| 3 |
import ( |
| 4 |
"bufio" |
| 5 |
"io" |
| 6 |
"os" |
| 7 |
) |
| 8 |
|
| 9 |
// writeFlusher is the interface that groups the basic Write and Flush methods. |
| 10 |
type writeFlusher interface { |
| 11 |
io.Writer |
| 12 |
Flush() error |
| 13 |
} |
| 14 |
|
| 15 |
var newBufWriter = func(w io.Writer) writeFlusher { |
| 16 |
return bufio.NewWriter(w) |
| 17 |
} |
| 18 |
|
| 19 |
// write writes the input byte data to the CSS file. |
| 20 |
func write(path string, bc <-chan []byte, berrc <-chan error) (<-chan struct{}, <-chan error) { |
| 21 |
done := make(chan struct{}) |
| 22 |
errc := make(chan error) |
| 23 |
|
| 24 |
go func() { |
| 25 |
f, err := os.Create(path) |
| 26 |
|
| 27 |
if err != nil { |
| 28 |
errc <- err |
| 29 |
return |
| 30 |
} |
| 31 |
|
| 32 |
defer f.Close() |
| 33 |
|
| 34 |
w := newBufWriter(f) |
| 35 |
|
| 36 |
for { |
| 37 |
select { |
| 38 |
case b, ok := <-bc: |
| 39 |
if !ok { |
| 40 |
if err := w.Flush(); err != nil { |
| 41 |
errc <- err |
| 42 |
return |
| 43 |
} |
| 44 |
|
| 45 |
done <- struct{}{} |
| 46 |
|
| 47 |
return |
| 48 |
} |
| 49 |
|
| 50 |
if _, err := w.Write(b); err != nil { |
| 51 |
errc <- err |
| 52 |
return |
| 53 |
} |
| 54 |
case err := <-berrc: |
| 55 |
errc <- err |
| 56 |
return |
| 57 |
} |
| 58 |
} |
| 59 |
}() |
| 60 |
|
| 61 |
return done, errc |
| 62 |
} |
