streaming json decode.go

func DecodeJson(r io.ReadCloser, itemChan chan<- []interface{}) error {
	defer close(itemChan)
	dec := json.NewDecoder(r)

	// read open bracket
	_, err := dec.Token()
	if err != nil {
		panic(err)
	}

	// while the array contains values
	for dec.More() {
		var row []interface{}
		// decode an array value (Message)
		err := dec.Decode(&row)
		if err != nil {
			panic(err)
		}
		itemChan <- row
		//fmt.Printf("%v: %v\n", row[0], row[1])
	}

	// read closing bracket
	_, err = dec.Token()
	if err != nil {
		panic(err)
	}
	return err
}

func main() {
	r := somereader
	itemChan := make(chan []interface{})
	go DecodeJson(reader, itemChan)
	
	for item:= range itemChan {
		//do something
	}
}