diff --git a/h11/_connection.py b/h11/_connection.py index effa42c..d175270 100644 --- a/h11/_connection.py +++ b/h11/_connection.py @@ -395,7 +395,9 @@ def receive_data(self, data: bytes) -> None: else: self._receive_buffer_closed = True - def _extract_next_receive_event(self) -> Union[Event, Type[NEED_DATA], Type[PAUSED]]: + def _extract_next_receive_event( + self, + ) -> Union[Event, Type[NEED_DATA], Type[PAUSED]]: state = self.their_state # We don't pause immediately when they enter DONE, because even in # DONE state we can still process a ConnectionClosed() event. But