code: func New() *Streamer {
  	s := &Streamer{
  		event:         make(chan []byte, 1),
  		clients:       make(map[client]bool),
  		connecting:    make(chan client),
  		disconnecting: make(chan client),
  		bufSize:       2,
  	}
  
  	s.run()
  	return s
  }
docs: // New returns a new initialized SSE Streamer