code

func (lr *LinesReader) Next() (reader.Message, error) {
//    findKey := false
    //TODO:
    for {
        message, err := lr.reader.Next()
        logp.Debug("lines", "Next() message.Content:%s", message.Content)

        line := string(message.Content)
        if (matchAny(lr.linesMatchers, line)) {
            logp.Debug("lines", "Next() match()")
        }

        return message, err
    }
}