rdfio/rdf2smw

package components
 
import (
    "io"
    "log"
    str "strings"
 
    "github.com/knakk/rdf"
)
 
exported type TripleParser should have comment or be unexported
type TripleParser struct {
    In  chan string
    Out chan rdf.Triple
}
 
exported function NewTripleParser should have comment or be unexported
func NewTripleParser() *TripleParser {
    return &TripleParser{
        In:  make(chan string, BUFSIZE),
        Out: make(chan rdf.Triple, BUFSIZE),
    }
}
 
exported method TripleParser.Run should have comment or be unexported
func (p *TripleParser) Run() {
    defer close(p.Out)
    for line := range p.In {
        lineReader := str.NewReader(line)
        dec := rdf.NewTripleDecoder(lineReader, rdf.Turtle)
Similar blocks of code found in 2 locations. Consider refactoring.
        for triple, err := dec.Decode(); err != io.EOF; triple, err = dec.Decode() {
            if err != nil {
                log.Fatal("Could not encode to triple: ", err.Error())
            } else if triple.Subj != nil && triple.Pred != nil && triple.Obj != nil {
                p.Out <- triple
            } else {
                log.Fatal("Something was encoded as nil in the triple:", triple)
            }
        }
    }
}