Better shutdown sequence (taken from official example) & some renamings

build/conformance/Dockerfile

@@ -12,8 +12,7 @@ RUN <<EOF
     CONFORMANCE_URL="https://github.com/connectrpc/conformance/releases/download/${CONFORMANCE_VERSION}/connectconformance-${CONFORMANCE_VERSION}-${UNAME_OS}-${UNAME_ARCH}.tar.gz"
     echo "Downloading conformance from ${CONFORMANCE_URL}"
     curl -sSL "${CONFORMANCE_URL}" -o conformance.tgz
-    tar -xvzf conformance.tgz
-    chmod +x connectconformance
+    tar -xvzf conformance.tgz && chmod +x connectconformance
 EOF
 
 FROM sbt_image AS build
@@ -40,7 +39,7 @@ RUN mkdir "/logs"
 RUN echo ">>>>> Running stable tests <<<<<"
 RUN LOGS_PATH="/logs" \
     ./connectconformance \
-    --conf suite-stable.yaml \
+    --conf suite.yaml \
     --mode server \
     --parallel 1 \
     -v -vv --trace \
@@ -51,7 +50,7 @@ RUN LOGS_PATH="/logs" \
 RUN echo ">>>>> Running unstable tests <<<<<"
 RUN LOGS_PATH="/logs" \
     ./connectconformance \
-    --conf suite.yaml \
+    --conf suite-unstable.yaml \
     --mode server \
     --parallel 1 \
     -v -vv --trace \

build/conformance/suite-stable.yaml → build/conformance/suite-unstable.yaml

@@ -1,8 +1,8 @@
 # https://github.com/connectrpc/conformance/blob/main/docs/configuring_and_running_tests.md#configuration-files
 features:
-  versions: [ HTTP_VERSION_1, HTTP_VERSION_2 ]
+  versions: [ HTTP_VERSION_1 ]
   protocols: [ PROTOCOL_CONNECT ]
-  codecs: [ CODEC_JSON ]
+  codecs: [ CODEC_PROTO ]
   stream_types: [ STREAM_TYPE_UNARY ]
   supports_tls: false
   supports_trailers: false

build/conformance/suite.yaml

@@ -1,8 +1,8 @@
 # https://github.com/connectrpc/conformance/blob/main/docs/configuring_and_running_tests.md#configuration-files
 features:
-  versions: [ HTTP_VERSION_1 ]
+  versions: [ HTTP_VERSION_1, HTTP_VERSION_2 ]
   protocols: [ PROTOCOL_CONNECT ]
-  codecs: [ CODEC_PROTO ]
+  codecs: [ CODEC_JSON ]
   stream_types: [ STREAM_TYPE_UNARY ]
   supports_tls: false
   supports_trailers: false

core/src/main/scala/org/ivovk/connect_rpc_scala/grpc/ClientCalls.scala

@@ -23,6 +23,7 @@ object ClientCalls {
         call.start(CallbackListener[Resp](cb), headers)
         call.sendMessage(request)
         call.halfClose()
+        // request 2 messages to catch a case when a server sends more than one message
         call.request(2)
 
         Some(Async[F].delay(call.cancel("Cancelled", null)))

core/src/main/scala/org/ivovk/connect_rpc_scala/grpc/InProcessChannelBridge.scala

@@ -51,6 +51,13 @@ object InProcessChannelBridge {
             s"GRPC server did not shut down in $waitForShutdown, consider increasing shutdown timeout"
           )
         }
+
+        val res2 = s.shutdownNow().awaitTermination(waitForShutdown.toMillis, TimeUnit.MILLISECONDS)
+        if (!res2) {
+          logger.warn(
+            s"GRPC server did not shut down in $waitForShutdown, consider increasing shutdown timeout"
+          )
+        }
       }
 
     Resource.make(acquire)(release)