auracaster/bumble_mirror
3
0
Fork 1
mirror of https://github.com/google/bumble.git synced 2026-05-09 04:08:02 +00:00
Code Issues Packages Projects Releases Wiki Activity

Merge pull request #280 from zxzxwu/device_typing

Browse Source 
Add terminated to TransportSource protocol
This commit is contained in:
zxzxwu
2023-09-12 20:46:35 +08:00
committed by GitHub
parent 56139c622f 548d5597c0
commit 80824f3fc1
1 changed files with 3 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
bumble/transport/common.py
View File

@@ -63,6 +63,8 @@ class TransportSink(Protocol):
class TransportSource(Protocol): class TransportSource(Protocol):
terminated: asyncio.Future[None]
def set_packet_sink(self, sink: TransportSink) -> None: def set_packet_sink(self, sink: TransportSink) -> None:
... ...
@@ -430,6 +432,7 @@ class SnoopingTransport(Transport):
def __init__(self, source: TransportSource, snooper: Snooper): def __init__(self, source: TransportSource, snooper: Snooper):
self.source = source self.source = source
self.snooper = snooper self.snooper = snooper
self.terminated = source.terminated
def set_packet_sink(self, sink: TransportSink) -> None: def set_packet_sink(self, sink: TransportSink) -> None:
self.sink = sink self.sink = sink