From 9c7089c8fff039ba41ed14ee53ac3bf4cfb595bd Mon Sep 17 00:00:00 2001
From: Gilles Boccon-Gibod <bok@bok.net>
Date: Sun, 19 Nov 2023 11:36:38 -0800
Subject: [PATCH] terminate when unplugged

---
 bumble/transport/usb.py | 8 +++++---
 1 file changed, 5 insertions(+), 3 deletions(-)

diff --git a/bumble/transport/usb.py b/bumble/transport/usb.py
index baeb27f..d48b239 100644
--- a/bumble/transport/usb.py
+++ b/bumble/transport/usb.py
@@ -24,9 +24,10 @@ import platform
 
 import usb1
 
-from .common import Transport, ParserSource
-from .. import hci
-from ..colors import color
+from bumble.transport.common import Transport, ParserSource
+from bumble import hci
+from bumble.colors import color
+from bumble.utils import AsyncRunner
 
 
 # -----------------------------------------------------------------------------
@@ -271,6 +272,7 @@ async def open_usb_transport(spec: str) -> Transport:
                 logger.warning(
                     color(f'!!! IN transfer not completed: status={status}', 'red')
                 )
+                self.loop.call_soon_threadsafe(self.on_transport_lost)
 
         async def dequeue(self):
             while not self.closed: