consumer/async.go
func (c *Consumer) Stream(appGuid string, authToken string) (outputChan <-chan *events.Envelope, errorChan <-chan error) {
	return c.runStream(appGuid, authToken, true)
}
func (c *Consumer) Stream(appGuid string, authToken string) (outputChan <-chan *events.Envelope, errorChan <-chan error) {
	return c.runStream(appGuid, authToken, true)
}
func ( c * Consumer ) Stream ( appGuid string , authToken string ) ( outputChan <- chan * events . Envelope , errorChan <- chan error ) { return c . runStream ( appGuid , authToken , true ) }
// 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.
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 .