add buffer check back

nameko · Sep 21, 2023 · b322b9d · b322b9d
1 parent e1c6f55
commit b322b9d
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/nameko_grpc/streams.py b/nameko_grpc/streams.py
@@ -168,7 +168,7 @@ def headers_to_send(self, defer_until_data=True):
         if self.headers_sent or len(self.headers) == 0:
             return False
 
-        if defer_until_data and self.queue.empty():
+        if defer_until_data and self.queue.empty() and self.buffer.empty():
             return False
 
         self.headers_sent = True