()
| 94 | } |
| 95 | |
| 96 | func (p *Pipeline) hasStarted() bool { |
| 97 | return atomic.LoadUint32(&p.started) != 0 |
| 98 | } |
| 99 | |
| 100 | // Add appends one or more stages to the pipeline. |
| 101 | func (p *Pipeline) Add(stages ...Stage) { |
no outgoing calls
no test coverage detected