never let it leak

aiohttp/web_ws.py

@@ -496,12 +496,15 @@ async def receive(self, timeout: Optional[float] = None) -> WSMessage:
  self._closing = True
  self._close_code = msg.data
  # Could be closed while awaiting reader.
- if not self._closed and self._autoclose: # type: ignore[redundant-expr]
+ if not self._closed:
  # The client is going to close the connection
  # out from under us so we do not want to drain
  # any pending writes as it will likely result
  # writing to a broken pipe.
- await self.close(drain=False)
+ if self._autoclose:
+ await self.close(drain=False)
+ else:
+ self._set_code_close_transport(msg.data)
  elif msg.type == WSMsgType.CLOSING:
  self._closing = True
  elif msg.type == WSMsgType.PING and self._autoping: