From b062bdf9988ba3ff3cfd52da65bfcc8d230e1213 Mon Sep 17 00:00:00 2001 From: Junzi Sun Date: Mon, 26 Aug 2019 16:38:36 +0200 Subject: [PATCH] fix local buffer bug --- pyModeS/streamer/source.py | 8 ++++++++ 1 file changed, 8 insertions(+) diff --git a/pyModeS/streamer/source.py b/pyModeS/streamer/source.py index 761f877..c8273e1 100644 --- a/pyModeS/streamer/source.py +++ b/pyModeS/streamer/source.py @@ -6,6 +6,9 @@ from pyModeS.extra.rtlreader import RtlReader class NetSource(TcpClient): def __init__(self, host, port, rawtype): super(NetSource, self).__init__(host, port, rawtype) + self.reset_local_buffer() + + def reset_local_buffer(self): self.local_buffer_adsb_msg = [] self.local_buffer_adsb_ts = [] self.local_buffer_commb_msg = [] @@ -41,11 +44,15 @@ class NetSource(TcpClient): "commb_msg": self.local_buffer_commb_msg, } ) + self.reset_local_buffer() class RtlSdrSource(RtlReader): def __init__(self): super(RtlSdrSource, self).__init__() + self.reset_local_buffer() + + def reset_local_buffer(self): self.local_buffer_adsb_msg = [] self.local_buffer_adsb_ts = [] self.local_buffer_commb_msg = [] @@ -81,3 +88,4 @@ class RtlSdrSource(RtlReader): "commb_msg": self.local_buffer_commb_msg, } ) + self.reset_local_buffer()