From e1c6f552b1bdbd8444687c357d0339c80fbe8b58 Mon Sep 17 00:00:00 2001 From: Stephen Collinson Date: Thu, 21 Sep 2023 15:35:15 +0100 Subject: [PATCH] remove buffer check --- nameko_grpc/streams.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/nameko_grpc/streams.py b/nameko_grpc/streams.py index 1802d48..348f915 100644 --- 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() and self.buffer.empty(): + if defer_until_data and self.queue.empty(): return False self.headers_sent = True