@@ -15,11 +15,11 @@ async def test_read_and_commit_message(
1515 self , driver , topic_path , topic_with_messages , topic_consumer
1616 ):
1717
18- reader = driver .topic_client .topic_reader (topic_consumer , topic_path )
18+ reader = driver .topic_client .reader (topic_consumer , topic_path )
1919 batch = await reader .receive_batch ()
2020 await reader .commit_with_ack (batch )
2121
22- reader = driver .topic_client .topic_reader (topic_consumer , topic_path )
22+ reader = driver .topic_client .reader (topic_consumer , topic_path )
2323 batch2 = await reader .receive_batch ()
2424 assert batch .messages [0 ] != batch2 .messages [0 ]
2525
@@ -36,10 +36,10 @@ def test_read_message(
3636 def test_read_and_commit_message (
3737 self , driver_sync , topic_path , topic_with_messages , topic_consumer
3838 ):
39- reader = driver_sync .topic_client .topic_reader (topic_consumer , topic_path )
39+ reader = driver_sync .topic_client .reader (topic_consumer , topic_path )
4040 batch = reader .receive_batch ()
4141 reader .commit_with_ack (batch )
4242
43- reader = driver_sync .topic_client .topic_reader (topic_consumer , topic_path )
43+ reader = driver_sync .topic_client .reader (topic_consumer , topic_path )
4444 batch2 = reader .receive_batch ()
4545 assert batch .messages [0 ] != batch2 .messages [0 ]
0 commit comments