alex/goldsmith
1
Fork 0
Code Releases Activity

WIP

Browse Source
This commit is contained in:
Alex Yatskov 2015-12-17 12:58:28 +09:00
parent fdc5126a1e
commit ac600d147e
1 changed files with 8 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
goldsmith.go
View File

@ -58,7 +58,7 @@ func (gs *goldsmith) queueFiles() {
files := make(chan string) files := make(chan string)
go scanDir(gs.srcDir, files, nil) go scanDir(gs.srcDir, files, nil)
s := gs.makeStage() s := gs.newStage()
go func() { go func() {
defer close(s.output) defer close(s.output)
@ -145,8 +145,12 @@ func (gs *goldsmith) exportFile(file *File) {
} }
} }
func (gs *goldsmith) makeStage() *stage { func (gs *goldsmith) newStage() *stage {
s := &stage{output: make(chan *File)} s := &stage{
gs: gs,
output: make(chan *File),
}
if len(gs.stages) > 0 { if len(gs.stages) > 0 {
s.input = gs.stages[len(gs.stages)-1].output s.input = gs.stages[len(gs.stages)-1].output
} }
@ -205,7 +209,7 @@ func (gs *goldsmith) refFile(path string) {
} }
func (gs *goldsmith) Chain(p Plugin) Goldsmith { func (gs *goldsmith) Chain(p Plugin) Goldsmith {
go gs.chain(gs.makeStage(), p) go gs.chain(gs.newStage(), p)
return gs return gs
} }