package pipe func (w *Worker) Pause() (e error) { return } func (w *Worker) Resume() (e error) { return }