def scan_trace_deltat()

in src/rosbridge/timeseq.py [0:0]

• 12 lines of code
• 5 McCabe index (conditional complexity)

def scan_trace_deltat(dir, channels, deltat, sample_pair_cb):
    queue = collections.deque()
    def sample_cb(ts, samples):
        queue.append((ts, samples))
        while len(queue) > 1:
            deltat1 = queue[-1][0] - queue[0][0]
            if deltat1 < deltat: break
            old = queue.popleft()
            if deltat1 >= 0.95 * deltat:
                if 0: print deltat1, ts, old[0]
                sample_pair_cb(old[1], samples)
    scan_trace(dir, channels, sample_cb)