ch buffer 1
Vladimir Bauer
9 years ago
| 67 | 67 | alpha: 0.25, |
| 68 | 68 | width: width, |
| 69 | 69 | |
| 70 | incrCh: make(chan int64), | |
| 70 | incrCh: make(chan int64, 1), | |
| 71 | 71 | trimLeftCh: make(chan bool), |
| 72 | 72 | trimRightCh: make(chan bool), |
| 73 | stateReqCh: make(chan chan state), | |
| 73 | stateReqCh: make(chan chan state, 1), | |
| 74 | 74 | decoratorCh: make(chan *decorator), |
| 75 | 75 | flushedCh: make(chan struct{}), |
| 76 | 76 | removeReqCh: make(chan struct{}), |
| 148 | 148 | return b |
| 149 | 149 | } |
| 150 | 150 | |
| 151 | // ProxyReader wrapper for io operations, like io.Copy | |
| 151 | 152 | func (b *Bar) ProxyReader(r io.Reader) *Reader { |
| 152 | 153 | return &Reader{r, b} |
| 153 | 154 | } |
| 172 | 173 | if b.isDone() { |
| 173 | 174 | return b.lastState.current |
| 174 | 175 | } |
| 175 | ch := make(chan state) | |
| 176 | ch := make(chan state, 1) | |
| 176 | 177 | b.stateReqCh <- ch |
| 177 | 178 | state := <-ch |
| 178 | 179 | return state.current |
| 207 | 208 | if b.isDone() { |
| 208 | 209 | return b.draw(b.lastState, width) |
| 209 | 210 | } |
| 210 | ch := make(chan state) | |
| 211 | ch := make(chan state, 1) | |
| 211 | 212 | b.stateReqCh <- ch |
| 212 | 213 | return b.draw(<-ch, width) |
| 213 | 214 | } |