From 50e5a2f3b0a1629f18495b0424e3a8e670b0645d Mon Sep 17 00:00:00 2001
From: Alan Chiu <awlchiu@gmail.com>
Date: Wed, 10 May 2023 15:08:51 -0700
Subject: [PATCH] cu

---
 .../build/buf/connect/protocols/ConnectInterceptor.kt    | 9 ++++-----
 1 file changed, 4 insertions(+), 5 deletions(-)

diff --git a/library/src/main/kotlin/build/buf/connect/protocols/ConnectInterceptor.kt b/library/src/main/kotlin/build/buf/connect/protocols/ConnectInterceptor.kt
index f682d02e..e90c7cc0 100644
--- a/library/src/main/kotlin/build/buf/connect/protocols/ConnectInterceptor.kt
+++ b/library/src/main/kotlin/build/buf/connect/protocols/ConnectInterceptor.kt
@@ -71,17 +71,16 @@ internal class ConnectInterceptor(
                     buffer
                 }
                 val finalRequestBody = if (requestCompression?.shouldCompress(requestMessage) == true) {
-                    requestHeaders.put(CONTENT_ENCODING, listOf(requestCompression!!.compressionPool.name()))
+                    requestHeaders.put(CONTENT_ENCODING, listOf(requestCompression.compressionPool.name()))
                     requestCompression.compressionPool.compress(requestMessage)
                 } else {
                     requestMessage
                 }
-
                 val serializationStrategy = clientConfig.serializationStrategy
-                val requestCodec = serializationStrategy.codec(request.methodSpec!!.requestClass)
-                val useGet = clientConfig.enableGet &&
+                val requestCodec = serializationStrategy.codec(request.methodSpec.requestClass)
+                val isCacheableGetMethod = clientConfig.enableGet &&
                     request.methodSpec.idempotency == Idempotency.NO_SIDE_EFFECTS
-                if (useGet) {
+                if (isCacheableGetMethod) {
                     val url = getUrlFromMethodSpec(
                         request,
                         requestCodec,