code: func (s *BufferedSender) Start() {
  	// write lock to start running
  	s.runmx.Lock()
  	defer s.runmx.Unlock()
  	if s.running {
  		return
  	}
  
  	s.running = true
  	s.bufs = make(chan *bytes.Buffer, 32)
  	go s.run()
  }
docs: // Start Buffered Sender
  // Begins ticker and read loop