Function GoodStream

go/test/testing.go:32–54

GoodStream checks whether there's errors in `stream`

(stream chan interface{})

// GoodStream checks whether there's errors in `stream`
func GoodStream(stream chan interface{}) (bool, string) {
	lastResp := list.New()
	keepSize := 10

	for rsp := range stream {
		switch rsp.(type) {
		case error:
			var ss []string
			for e := lastResp.Front(); e != nil; e = e.Next() {
				if s, ok := e.Value.(string); ok {
					ss = append(ss, s)
				}
			}
			return false, fmt.Sprintf("%v: %s", rsp, strings.Join(ss, "\n"))
		}
		lastResp.PushBack(rsp)
		if lastResp.Len() > keepSize {
			e := lastResp.Front()
			lastResp.Remove(e)
		}
	}
	return true, ""
}