Avoid yielding messages on GeneratorExit in sync server (#90)

Signed-off-by: Anuraag Agrawal <anuraaga@gmail.com>

Author: anuraaga

conformance/test/server.py

@@ -538,8 +538,10 @@ async def serve_gunicorn(
     args = [
         "--bind=127.0.0.1:0",
         "--workers=4",
-        "--worker-class=gevent",
+        "--worker-class=gthread",
+        "--threads=16",
         "--reuse-port",
+        "--keep-alive=0",
     ]
     if certfile:
         args.append(f"--certfile={certfile}")

pyproject.toml

@@ -44,7 +44,7 @@ dev = [
     "hypercorn==0.17.3",
     "granian==2.5.7",
     "grpcio-tools==1.76.0",
-    "gunicorn[gevent]==23.0.0",
+    "gunicorn==23.0.0",
     "just-bin==1.42.4; sys_platform != 'win32'",
     "pyright[nodejs]==1.1.405",
     "pyvoy==0.2.0",

src/connectrpc/_server_sync.py

@@ -574,14 +574,14 @@ def _response_stream(
             yield body
     except Exception as e:
         error = e
-    finally:
-        yield _end_response(
-            writer.end(
-                ctx.response_trailers(),
-                ConnectWireError.from_exception(error) if error else None,
-            ),
-            send_trailers,
-        )
+
+    yield _end_response(
+        writer.end(
+            ctx.response_trailers(),
+            ConnectWireError.from_exception(error) if error else None,
+        ),
+        send_trailers,
+    )
 
 
 def _consume_single_request(stream: Iterator[_REQ]) -> _REQ: