Function mustCompress

rpc_util_test.go:424–436

mustCompress gzip-compresses input and returns it as a BufferSlice, failing the test if compression fails.

(t *testing.T, input []byte)

// mustCompress gzip-compresses input and returns it as a BufferSlice,
// failing the test if compression fails.
func mustCompress(t *testing.T, input []byte) mem.BufferSlice {
	t.Helper()
	var buf bytes.Buffer
	gz := gzip.NewWriter(&buf)
	if _, err := gz.Write(input); err != nil {
		t.Fatalf("mustCompress() failed to write data: %v", err)
	}
	if err := gz.Close(); err != nil {
		t.Fatalf("mustCompress() failed to close gzip writer: %v", err)
	}
	compressedData := buf.Bytes()
	return mem.BufferSlice{mem.NewBuffer(&compressedData, nil)}
}

// MockDecompressor is a mock implementation of a decompressor used for testing purposes.
// It simulates decompression behavior, returning either decompressed data or an error based on the ShouldError flag.