RepeatedlyStateMachine extends TriggerStateMachine { @Override public void onElement(OnElementContext c) throws Exception { getRepeated(c).invokeOnElement(c); } private  RepeatedlyStateMachine(TriggerStateMachine repeated); static RepeatedlyStateMachine forever(TriggerStateMachine repeated); @Override void onElement(OnElementContext c); @Override void onMerge(OnMergeContext c); @Override boolean shouldFire(TriggerStateMachine.TriggerContext context); @Override void onFire(TriggerContext context); @Override String toString();  }
@Test public void testOnElement() throws Exception { setUp(FixedWindows.of(Duration.millis(10))); tester.injectElements(37); verify(mockTrigger).onElement(Mockito.any()); }