@@ -126,7 +126,7 @@ async def test_listener_listen(
126
126
listener_table_name = listener_table_name ,
127
127
)
128
128
129
- listener .abort_listen ()
129
+ await listener .shutdown ()
130
130
131
131
132
132
@pytest .mark .usefixtures ("create_table_for_listener_tests" )
@@ -152,7 +152,7 @@ async def test_listener_asynciterator(
152
152
assert listener_msg .payload == TEST_PAYLOAD
153
153
break
154
154
155
- listener .abort_listen ()
155
+ await listener .shutdown ()
156
156
157
157
158
158
@pytest .mark .usefixtures ("create_table_for_listener_tests" )
@@ -175,7 +175,7 @@ async def test_listener_abort(
175
175
listener_table_name = listener_table_name ,
176
176
)
177
177
178
- listener .abort_listen ()
178
+ await listener .shutdown ()
179
179
180
180
await clear_test_table (
181
181
psql_pool = psql_pool ,
@@ -261,7 +261,7 @@ async def test_listener_more_than_one_callback(
261
261
262
262
assert data_result ["channel" ] == additional_channel
263
263
264
- listener .abort_listen ()
264
+ await listener .shutdown ()
265
265
266
266
267
267
@pytest .mark .usefixtures ("create_table_for_listener_tests" )
@@ -290,7 +290,7 @@ async def test_listener_clear_callbacks(
290
290
is_insert_exist = False ,
291
291
)
292
292
293
- listener .abort_listen ()
293
+ await listener .shutdown ()
294
294
295
295
296
296
@pytest .mark .usefixtures ("create_table_for_listener_tests" )
@@ -317,4 +317,4 @@ async def test_listener_clear_all_callbacks(
317
317
is_insert_exist = False ,
318
318
)
319
319
320
- listener .abort_listen ()
320
+ await listener .shutdown ()
0 commit comments