Skip to content

Commit

Permalink
changing barrier stopC type to an empty struct channel
Browse files Browse the repository at this point in the history
  • Loading branch information
sputnik13 committed Nov 28, 2017
1 parent 165d255 commit 2d78b4f
Showing 1 changed file with 2 additions and 2 deletions.
4 changes: 2 additions & 2 deletions barrier.go
Original file line number Diff line number Diff line change
Expand Up @@ -89,7 +89,7 @@ type idleBarrier struct {
timer *time.Timer
wg sync.WaitGroup
outs []edge.StatsEdge
stopC chan interface{}
stopC chan struct{}
}

func newIdleBarrier(name string, group edge.GroupInfo, idle time.Duration, outs []edge.StatsEdge) *idleBarrier {
Expand All @@ -101,7 +101,7 @@ func newIdleBarrier(name string, group edge.GroupInfo, idle time.Duration, outs
timer: time.NewTimer(idle),
wg: sync.WaitGroup{},
outs: outs,
stopC: make(chan interface{}, 1),
stopC: make(chan struct{}, 1),
}

r.Init()
Expand Down

0 comments on commit 2d78b4f

Please sign in to comment.