code: func newEventStreams(c *Context) (empire.MultiEventStream, error) {
  	var streams empire.MultiEventStream
  	switch c.String(FlagEventsBackend) {
  	case "sns":
  		e, err := newSNSEventStream(c)
  		if err != nil {
  			return streams, err
  		}
  		streams = append(streams, e)
  	case "stdout":
  		e, err := newStdoutEventStream(c)
  		if err != nil {
  			return streams, err
  		}
  		streams = append(streams, e)
  	default:
  		e := empire.NullEventStream
  		streams = append(streams, e)
  	}
  
  	if c.String(FlagLogsStreamer) == "kinesis" {
  		e, err := newAppEventStream(c)
  		if err != nil {
  			return streams, err
  		}
  		streams = append(streams, e)
  	}
  	return streams, nil
  }
docs: // Events ==============================