@@ -95,13 +95,13 @@ async def send_with_gzip(self, message: Message) -> None:
9595 self .started = True
9696 body = message .get ("body" , b"" )
9797 more_body = message .get ("more_body" , False )
98- if (len (body ) < ( self .minimum_size and not more_body ) ) or any (
98+ if (( len (body ) < self .minimum_size ) and not more_body ) or any (
9999 value == b'application/octet-stream'
100100 for header , value in self .initial_message ["headers" ]
101101 ):
102102 # Don't apply GZip to small outgoing responses or octet-streams.
103103 await self .send (self .initial_message )
104- await self .send (message )
104+ await self .send (message ) # pylint: disable=unreachable
105105 elif not more_body :
106106 # Standard GZip response.
107107 self .gzip_file .write (body )
@@ -115,7 +115,7 @@ async def send_with_gzip(self, message: Message) -> None:
115115 message ["body" ] = body
116116
117117 await self .send (self .initial_message )
118- await self .send (message )
118+ await self .send (message ) # pylint: disable=unreachable
119119 else :
120120 # Initial body in streaming GZip response.
121121 headers = MutableHeaders (raw = self .initial_message ["headers" ])
@@ -129,7 +129,7 @@ async def send_with_gzip(self, message: Message) -> None:
129129 self .gzip_buffer .truncate ()
130130
131131 await self .send (self .initial_message )
132- await self .send (message )
132+ await self .send (message ) # pylint: disable=unreachable
133133
134134 elif message_type == "http.response.body" :
135135 # Remaining body in streaming GZip response.
0 commit comments