code: func (c *Consumer) Stream(appGuid string, authToken string) (outputChan <-chan *events.Envelope, errorChan <-chan error) {
  	return c.runStream(appGuid, authToken, true)
  }
docs: // Stream listens indefinitely for all log and event messages.
  //
  // Messages are presented in the order received from the loggregator server.
  // Chronological or other ordering is not guaranteed. It is the responsibility
  // of the consumer of these channels to provide any desired sorting mechanism.
  //
  // Whenever an error is encountered, the error will be sent down the error
  // channel and Stream will attempt to reconnect indefinitely.