@@ -1806,9 +1806,7 @@ def _receive_window_update_frame(self, frame: WindowUpdateFrame) -> tuple[list[F
18061806 )
18071807
18081808 # FIXME: Should we split this into one event per active stream?
1809- window_updated_event = WindowUpdated ()
1810- window_updated_event .stream_id = 0
1811- window_updated_event .delta = frame .window_increment
1809+ window_updated_event = WindowUpdated (stream_id = 0 , delta = frame .window_increment )
18121810 stream_events = [window_updated_event ]
18131811 frames = []
18141812
@@ -1825,17 +1823,16 @@ def _receive_ping_frame(self, frame: PingFrame) -> tuple[list[Frame], list[Event
18251823
18261824 evt : PingReceived | PingAckReceived
18271825 if "ACK" in frame .flags :
1828- evt = PingAckReceived ()
1826+ evt = PingAckReceived (ping_data = frame . opaque_data )
18291827 else :
1830- evt = PingReceived ()
1828+ evt = PingReceived (ping_data = frame . opaque_data )
18311829
18321830 # automatically ACK the PING with the same 'opaque data'
18331831 f = PingFrame (0 )
18341832 f .flags .add ("ACK" )
18351833 f .opaque_data = frame .opaque_data
18361834 frames .append (f )
18371835
1838- evt .ping_data = frame .opaque_data
18391836 events .append (evt )
18401837
18411838 return frames , events
@@ -1974,8 +1971,7 @@ def _receive_unknown_frame(self, frame: ExtensionFrame) -> tuple[list[Frame], li
19741971 self .config .logger .debug (
19751972 "Received unknown extension frame (ID %d)" , frame .stream_id ,
19761973 )
1977- event = UnknownFrameReceived ()
1978- event .frame = frame
1974+ event = UnknownFrameReceived (frame = frame )
19791975 return [], [event ]
19801976
19811977 def _local_settings_acked (self ) -> dict [SettingCodes | int , ChangedSetting ]:
0 commit comments