PYTHON-5781 Remove test_reads_data_in_multiple_chunks re-added by revert

Author: aclark4life

test/asynchronous/test_async_network_layer.py

@@ -155,31 +155,6 @@ async def test_close_with_exception_propagates_to_pending(self):
 
 
 class TestAsyncSocketReceive(AsyncUnitTest):
-    async def test_reads_data_in_multiple_chunks(self):
-        # Covers the loop in _async_socket_receive that accumulates short reads
-        # until the requested length has been received.
-        data = b"abcdefgh"
-        length = len(data)
-        chunk1, chunk2 = data[:4], data[4:]
-        mock_socket = MagicMock()
-        loop = asyncio.get_running_loop()
-        calls = 0
-
-        async def fake_recv_into(sock, buf):
-            nonlocal calls
-            if calls == 0:
-                buf[: len(chunk1)] = chunk1
-                calls += 1
-                return len(chunk1)
-            buf[: len(chunk2)] = chunk2
-            calls += 1
-            return len(chunk2)
-
-        with patch.object(loop, "sock_recv_into", new=AsyncMock(side_effect=fake_recv_into)):
-            result = await _async_socket_receive(mock_socket, length, loop)
-        self.assertEqual(bytes(result), data)
-        self.assertEqual(calls, 2)
-
     async def test_raises_on_connection_closed(self):
         # Covers the explicit `raise OSError("connection closed")` branch when
         # sock_recv_into returns 0.

test/test_network_layer.py

@@ -117,29 +117,6 @@ def test_unknown_opcode_raises(self):
 
 
 class TestReceiveData(UnitTest):
-    def test_reads_data_in_multiple_chunks(self):
-        # Covers the loop in receive_data that accumulates short reads until the
-        # requested length has been received.
-        data = b"abcdefgh"
-        chunk1, chunk2 = data[:4], data[4:]
-        conn = _make_conn()
-        calls = 0
-
-        def fake_recv_into(buf):
-            nonlocal calls
-            if calls == 0:
-                buf[: len(chunk1)] = chunk1
-                calls += 1
-                return len(chunk1)
-            buf[: len(chunk2)] = chunk2
-            calls += 1
-            return len(chunk2)
-
-        conn.conn.recv_into.side_effect = fake_recv_into
-        result = network_layer.receive_data(conn, len(data), deadline=None)
-        self.assertEqual(bytes(result), data)
-        self.assertEqual(calls, 2)
-
     def test_raises_on_connection_closed(self):
         # Covers the explicit `raise OSError("connection closed")` branch when
         # recv_into returns 0.