From 4581f1538976afddaacc915b5d04750ecc8caee5 Mon Sep 17 00:00:00 2001 From: karel rehor Date: Fri, 6 Nov 2026 16:37:33 +0100 Subject: [PATCH] chore: update asynchronous_batching.py to use exception in on_error function. --- examples/asynchronous_batching.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/examples/asynchronous_batching.py b/examples/asynchronous_batching.py index 722ca233..d5ce476f 100644 --- a/examples/asynchronous_batching.py +++ b/examples/asynchronous_batching.py @@ -56,7 +56,7 @@ async def async_write(batch): Write batches by subscribing to Rx generator """ batches.subscribe(on_next=lambda batch: print(f'Written batch... {len(batch)}'), - on_error=lambda ex: print(f'Unexpected error: {ex}'), + on_error=lambda ex: done.set_exception(ex), on_completed=lambda: done.set_result(0), scheduler=AsyncIOScheduler(asyncio.get_event_loop())) """