code: func (eventStream *EventStream) StartListening() {
  	eventStream.statusLock.Lock()
  	defer eventStream.statusLock.Unlock()
  	eventStream.open = true
  
  	go eventStream.listen()
  }
docs: // StartListening mark the event stream as open and start listening