@@ -113,27 +113,6 @@ async def test_compression_header_zlib_compressor_id(self):
113113 _ , compressor_id = protocol .process_compression_header ()
114114 self .assertEqual (compressor_id , 2 )
115115
116- async def test_message_complete_resolves_pending_future (self ):
117- protocol = await _make_protocol ()
118- protocol ._expecting_header = False
119- protocol ._expecting_compression = False
120- protocol ._message_size = 10
121- protocol ._message = memoryview (bytearray (10 ))
122- protocol ._message_index = 0
123- protocol ._op_code = 2013
124- protocol ._compressor_id = None
125- protocol ._response_to = 42
126-
127- future = asyncio .get_running_loop ().create_future ()
128- protocol ._pending_messages .append (future )
129-
130- protocol .buffer_updated (10 )
131- self .assertTrue (future .done ())
132- op_code , compressor_id , response_to , _ = future .result ()
133- self .assertEqual (op_code , 2013 )
134- self .assertIsNone (compressor_id )
135- self .assertEqual (response_to , 42 )
136-
137116 async def test_close_aborts_transport (self ):
138117 protocol = await _make_protocol ()
139118 protocol .close ()
0 commit comments