in kinesis/kinesis.go [610:628]
func zlibCompress(data []byte) ([]byte, error) {
var b bytes.Buffer
if data == nil {
return nil, fmt.Errorf("No data to compress. 'nil' value passed as data")
}
zw := zlib.NewWriter(&b)
_, err := zw.Write(data)
if err != nil {
return data, err
}
err = zw.Close()
if err != nil {
return data, err
}
return b.Bytes(), nil
}