Revert "EnableTriggerComplete waits for b.done if triggering complete event"
This reverts commit 769c54f1a34f427b0cc374f55a6a8ca12086aa90.
Vladimir Bauer
4 years ago
| 160 | 160 | // If bar has been incremented to the total, complete event is |
| 161 | 161 | // triggered right away. |
| 162 | 162 | func (b *Bar) EnableTriggerComplete() { |
| 163 | triggerComplete := make(chan bool) | |
| 164 | select { | |
| 165 | case b.operateState <- func(s *bState) { | |
| 166 | defer func() { | |
| 167 | triggerComplete <- s.triggerComplete | |
| 168 | }() | |
| 163 | select { | |
| 164 | case b.operateState <- func(s *bState) { | |
| 169 | 165 | if s.triggerComplete { |
| 170 | 166 | return |
| 171 | 167 | } |
| 177 | 173 | s.triggerComplete = true |
| 178 | 174 | } |
| 179 | 175 | }: |
| 180 | triggerComplete := <-triggerComplete | |
| 181 | if !triggerComplete { | |
| 182 | <-b.done | |
| 183 | } | |
| 184 | 176 | case <-b.done: |
| 185 | 177 | } |
| 186 | 178 | } |