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

Transport: Add termination protocol signature

Browse Source
This commit is contained in:
Josh Wu
2023-09-10 02:38:33 +08:00
parent 1e00c8f456
commit 548d5597c0
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