@Test public void testCountDecimate1() { CountDecimate f = new CountDecimate(3); QueueSink qs = new QueueSink(1); Connector.connect(f, qs); Pushable in = f.getPushableInput(0); Queue<Object> queue = qs.getQueue(0); for (int k = 0; k < 2; k++) { in.push(0); assertEquals(1, queue.size()); Utilities.queueContains(0, queue); in.push(1); assertTrue(queue.isEmpty()); in.push(2); assertTrue(queue.isEmpty()); in.push(3); Utilities.queueContains(3, queue); in.push(4); assertTrue(queue.isEmpty()); in.push(5); assertTrue(queue.isEmpty()); in.push(6); Utilities.queueContains(6, queue); f.reset(); } }
@Override public void reset() { super.reset(); m_current = 0; }
CountDecimate extends Decimate { @Override public void reset() { super.reset(); m_current = 0; } }
CountDecimate extends Decimate { @Override public void reset() { super.reset(); m_current = 0; } CountDecimate();  CountDecimate(int interval);  CountDecimate(int interval, boolean should_process_last_inputs); }
CountDecimate extends Decimate { @Override public void reset() { super.reset(); m_current = 0; } CountDecimate();  CountDecimate(int interval);  CountDecimate(int interval, boolean should_process_last_inputs); int getInterval(); @Override void reset(); @Override CountDecimate duplicate(boolean with_state); }
CountDecimate extends Decimate { @Override public void reset() { super.reset(); m_current = 0; } CountDecimate();  CountDecimate(int interval);  CountDecimate(int interval, boolean should_process_last_inputs); int getInterval(); @Override void reset(); @Override CountDecimate duplicate(boolean with_state);  }