online_wavelet_analysis.py 文件源码

def add_point(self, t, alt, az):

        self.window.append((t, alt, az))
        if self._current_window_size() < self.window_duration:
            return

        points = np.array(self.window)
        steady, current = np.array_split(points, 2)

        _, steady_cube = self.create_cube(steady)
        timestamps, current_cube = self.create_cube(current)

        t = self.denoise_and_compare_cubes(steady_cube, current_cube)
        self.trigger_criterion.append(list(t))
        self.trigger_criterion_timestamps.append(list(timestamps))

        has_triggered = self.check_trigger(t)
        new_duration = self.window_duration - self.step
        self._reduce_to_duration(new_duration)