Revert "Fix possible race running example test"

seherv · seherv · commit 97a1c2801ab9 · 2026-04-24T17:09:13.000+02:00
This reverts commit df5b0fc. Signed-off-by: Sergio Herrera <627709+seherv@users.noreply.github.com>
diff --git a/tests/examples/test_pubsub_streaming_async.py b/tests/examples/test_pubsub_streaming_async.py
@@ -6,6 +6,7 @@
     "Processing message: {'id': 3, 'message': 'hello world'} from TOPIC_B1...",
     "Processing message: {'id': 4, 'message': 'hello world'} from TOPIC_B1...",
     "Processing message: {'id': 5, 'message': 'hello world'} from TOPIC_B1...",
+    'Closing subscription...',
 ]
 
 EXPECTED_HANDLER_SUBSCRIBER = [
@@ -14,6 +15,7 @@
     "Processing message: {'id': 3, 'message': 'hello world'} from TOPIC_B2...",
     "Processing message: {'id': 4, 'message': 'hello world'} from TOPIC_B2...",
     "Processing message: {'id': 5, 'message': 'hello world'} from TOPIC_B2...",
+    'Closing subscription...',
 ]
 
 EXPECTED_PUBLISHER = [

Original file line number	Diff line number	Diff line change
`@@ -6,6 +6,7 @@`
`6`	`6`	`"Processing message: {'id': 3, 'message': 'hello world'} from TOPIC_B1...",`
`7`	`7`	`"Processing message: {'id': 4, 'message': 'hello world'} from TOPIC_B1...",`
`8`	`8`	`"Processing message: {'id': 5, 'message': 'hello world'} from TOPIC_B1...",`
	`9`	`+ 'Closing subscription...',`
`9`	`10`	`]`
`10`	`11`
`11`	`12`	`EXPECTED_HANDLER_SUBSCRIBER = [`
`@@ -14,6 +15,7 @@`
`14`	`15`	`"Processing message: {'id': 3, 'message': 'hello world'} from TOPIC_B2...",`
`15`	`16`	`"Processing message: {'id': 4, 'message': 'hello world'} from TOPIC_B2...",`
`16`	`17`	`"Processing message: {'id': 5, 'message': 'hello world'} from TOPIC_B2...",`
	`18`	`+ 'Closing subscription...',`
`17`	`19`	`]`
`18`	`20`
`19`	`21`	`EXPECTED_PUBLISHER = [`