Function processMessage

twitterdata/postprocess/postprocess.go:205–217

(writer io.Writer, message string)

}

func processMessage(writer io.Writer, message string) error {
	tweet, err := parseMessage(message)
	if err != nil {
		return err
	}

	// produce RDF data from tweet
	if err := tweetToJSON(writer, tweet); err != nil {
		return err
	}

	return nil
}

func parseMessage(message string) (*anaconda.Tweet, error) {
	var tweet anaconda.Tweet