code: func AsyncEvents(e EventStream) EventStream {
  	s := &asyncEventStream{
  		e:      e,
  		events: make(chan Event, 100),
  	}
  	go s.start()
  	return s
  }
docs: // AsyncEvents returns a new AsyncEventStream that will buffer upto 100 events
  // before applying backpressure.