code: func (sw *StreamWatcher) Stop() {
  	// Call Close() exactly once by locking and setting a flag.
  	sw.Lock()
  	defer sw.Unlock()
  	if !sw.stopped {
  		sw.stopped = true
  		sw.source.Close()
  	}
  }
docs: // Stop implements Interface.