go-twitterstream

usage

package main

import (
	"encoding/json"
	"github.com/soh335/go-twitterstream"
	"log"
)

func main() {
	client := &twitterstream.Client{
		ConsumerKey:     "...",
		ConsumerSecret:  "...",
		Token:           "...",
		TokenSecret:     "...",
		GzipCompression: true,
	}

	conn, err := client.Userstream("POST", map[string]string{"stringify_friend_ids": "true"})

	if err != nil {
		log.Fatal(err)
	}

	defer conn.Close()

	for {
		line, err := conn.Next()
		if err != nil {
			log.Fatal(err)
		}
		var item map[string]interface{}
		if err := json.Unmarshal(line, &item); err != nil {
			log.Fatal("json decode failed:" + err.Error())
		}
		log.Println(item)
	}
}