removed unused obj
This commit is contained in:
@ -22,8 +22,7 @@ class BSCache:
|
|||||||
|
|
||||||
|
|
||||||
def run(self, running):
|
def run(self, running):
|
||||||
channels = self.channels.keys()
|
configs = self.channels.values()
|
||||||
configs = self.channels.values()
|
|
||||||
with source(channels=configs, receive_timeout=-1) as src:
|
with source(channels=configs, receive_timeout=-1) as src:
|
||||||
while running.is_set():
|
while running.is_set():
|
||||||
msg = src.receive()
|
msg = src.receive()
|
||||||
|
Reference in New Issue
Block a user