Fix: Preserve transport metadata

Preserve transport metadata when wrapping with SnoopingTransport
This commit is contained in:
Charlie Boutier
2024-05-21 23:53:40 +00:00
committed by Slvr
parent e34f6b5fd3
commit 28e6229b24

View File

@@ -425,6 +425,10 @@ class SnoopingTransport(Transport):
class Source:
sink: TransportSink
@property
def metadata(self) -> dict[str, Any]:
return getattr(self.source, 'metadata', {})
def __init__(self, source: TransportSource, snooper: Snooper):
self.source = source
self.snooper = snooper