8207393961

Committed 08 Mar 2024 06:19PM UTC coverage: 71.198% (+6.3%) from 64.931%

Build # 8207393961

Build Type

push

github

Committed by

lisienskenderi

Commit Message

test

Run Details

1058 of 1486 relevant lines covered (71.2%)

0.71 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/PythonSensorsSimulator/Model/SimulatorThread.py

import time
from .Simulators.Simulator import Simulator
from .ComponentSimulatorThread import ComponentSimulatorThread
from .Writers.Writer import Writer
from .AdapterMisurazione import AdapterMisurazione

class SimulatorThread(ComponentSimulatorThread):

    def __init__(self, simulator: Simulator, writers: Writer, frequency: float = 10, data_to_generate: int = -1):
        super().__init__()
        self.__simulator = simulator
        self.__frequency = frequency
        self.__is_running = True
        self.__data_to_generate = data_to_generate
        self.__writers = writers

    def run(self) -> None:
        self.task()

    def task(self):
        last_measure = None
        while self.__is_running:
            if self.__data_to_generate == 0:
                self.stop()
            elif self.__data_to_generate > 0:
                self.__data_to_generate -= 1
            new_measure = self.__simulator.simulate()
            if last_measure is None or last_measure.get_value() != new_measure.get_value():
                #faccio in modo che venga inviato il dato solo se è differente dal precedente,
                #altrimenti non ha senso
                self.__writers.write(AdapterMisurazione(new_measure))
                last_measure = new_measure
            time.sleep(self.__frequency)

    def stop(self) -> None:
        self.__is_running = False

1	import time	×
2	from .Simulators.Simulator import Simulator	×
3	from .ComponentSimulatorThread import ComponentSimulatorThread	×
4	from .Writers.Writer import Writer	×
5	from .AdapterMisurazione import AdapterMisurazione	×
6
7	class SimulatorThread(ComponentSimulatorThread):	×
8
9	def __init__(self, simulator: Simulator, writers: Writer, frequency: float = 10, data_to_generate: int = -1):	×
10	super().__init__()	×
11	self.__simulator = simulator	×
12	self.__frequency = frequency	×
13	self.__is_running = True	×
14	self.__data_to_generate = data_to_generate	×
15	self.__writers = writers	×
16
17	def run(self) -> None:	×
18	self.task()	×
19
20	def task(self):	×
21	last_measure = None	×
22	while self.__is_running:	×
23	if self.__data_to_generate == 0:	×
24	self.stop()	×
25	elif self.__data_to_generate > 0:	×
26	self.__data_to_generate -= 1	×
27	new_measure = self.__simulator.simulate()	×
28	if last_measure is None or last_measure.get_value() != new_measure.get_value():	×
29	#faccio in modo che venga inviato il dato solo se è differente dal precedente,
30	#altrimenti non ha senso
31	self.__writers.write(AdapterMisurazione(new_measure))	×
32	last_measure = new_measure	×
33	time.sleep(self.__frequency)	×
34
35	def stop(self) -> None:	×
36	self.__is_running = False	×

ByteOps-swe / MVP / 8207393961

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous