File tree Expand file tree Collapse file tree 1 file changed +4
-4
lines changed
Expand file tree Collapse file tree 1 file changed +4
-4
lines changed Original file line number Diff line number Diff line change @@ -329,8 +329,8 @@ def transform(x):
329329
330330 assert result == [10 , 20 ]
331331
332- def test_collector_single_chunk_unwrap (self ):
333- """Test that a single chunk is unwrapped by Collector ."""
332+ def test_collector_single_chunk (self ):
333+ """Test that Collector emits a single chunk directly, not in a list ."""
334334
335335 def single_chunk (x ):
336336 yield x * 2
@@ -459,8 +459,8 @@ def stream_chunks(x):
459459
460460 asyncio .run (_test ())
461461
462- def test_async_collector_single_chunk_unwrap (self ):
463- """Async version: Test that a single chunk is unwrapped by Collector ."""
462+ def test_async_collector_single_chunk (self ):
463+ """Async version: Test that Collector emits a single chunk directly, not in a list ."""
464464
465465 async def _test ():
466466 def single_chunk (x ):
You can’t perform that action at this time.
0 commit comments