From 7d3b3749e8dbea14c286582bdd8af08f20c4c558 Mon Sep 17 00:00:00 2001
From: Sigurd Meldgaard <sigurdm@google.com>
Date: Tue, 28 Jan 2020 09:29:05 +0100
Subject: [PATCH] server: Cancel call when the outgoing messages are closed
 (#274)

---
 lib/src/server/handler.dart | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/lib/src/server/handler.dart b/lib/src/server/handler.dart
index 065d59e..038d969 100644
--- a/lib/src/server/handler.dart
+++ b/lib/src/server/handler.dart
@@ -77,6 +77,9 @@ class ServerHandler_ extends ServiceCall {
         .transform(grpcDecompressor())
         .listen(_onDataIdle,
             onError: _onError, onDone: _onDoneError, cancelOnError: true);
+    _stream.outgoingMessages.done.then((_) {
+      cancel();
+    });
   }
 
   /// Cancel response subscription, if active. If the stream exits with an