func()

in beater/pubsubbeat.go [207:222]

• 16 lines of code
• 4 McCabe index (conditional complexity)

func (bt *Pubsubbeat) decompress(m *pubsub.Message) error {
	rc := bt.zippers.Get().(*gzip.Reader)
	if err := rc.Reset(bytes.NewReader(m.Data)); err != nil {
		return fmt.Errorf("rc.Reset: %v", err)
	}
	var data bytes.Buffer
	if _, err := io.Copy(&data, rc); err != nil {
		return fmt.Errorf("io.Copy: %v", err)
	}
	if err := rc.Close(); err != nil {
		return fmt.Errorf("gzip.Close: %v", err)
	}
	bt.zippers.Put(rc)
	m.Data = data.Bytes()
	return nil
}