1919 MutableMapping ,
2020 Optional ,
2121 Pattern ,
22- Set ,
2322 Tuple ,
2423 Union ,
2524 cast ,
4342 reify ,
4443 sentinel ,
4544 set_exception ,
46- set_result ,
4745)
4846from .http_parser import RawRequestMessage
4947from .http_writer import HttpVersion
@@ -141,7 +139,6 @@ class BaseRequest(MutableMapping[str, Any], HeadersMixin):
141139 "_loop" ,
142140 "_transport_sslcontext" ,
143141 "_transport_peername" ,
144- "_disconnection_waiters" ,
145142 "__weakref__" ,
146143 )
147144
@@ -190,7 +187,6 @@ def __init__(
190187 self ._task = task
191188 self ._client_max_size = client_max_size
192189 self ._loop = loop
193- self ._disconnection_waiters : Set [asyncio .Future [None ]] = set ()
194190
195191 transport = self ._protocol .transport
196192 assert transport is not None
@@ -817,13 +813,8 @@ async def _prepare_hook(self, response: StreamResponse) -> None:
817813
818814 def _cancel (self , exc : BaseException ) -> None :
819815 set_exception (self ._payload , exc )
820- for fut in self ._disconnection_waiters :
821- set_result (fut , None )
822816
823817 def _finish (self ) -> None :
824- for fut in self ._disconnection_waiters :
825- fut .cancel ()
826-
827818 if self ._post is None or self .content_type != "multipart/form-data" :
828819 return
829820
@@ -832,19 +823,8 @@ def _finish(self) -> None:
832823 # NOTE: instances of files sent within multipart request body
833824 # NOTE: via HTTP POST request.
834825 for file_name , file_field_object in self ._post .items ():
835- if not isinstance (file_field_object , FileField ):
836- continue
837-
838- file_field_object .file .close ()
839-
840- async def wait_for_disconnection (self ) -> None :
841- loop = asyncio .get_event_loop ()
842- fut : asyncio .Future [None ] = loop .create_future ()
843- self ._disconnection_waiters .add (fut )
844- try :
845- await fut
846- finally :
847- self ._disconnection_waiters .remove (fut )
826+ if isinstance (file_field_object , FileField ):
827+ file_field_object .file .close ()
848828
849829
850830class Request (BaseRequest ):
0 commit comments