@Test public void testPollsFunctionRepeatedlyToSetAttribute() throws Exception { feed = FunctionFeed.builder() .entity(entity) .poll(new FunctionPollConfig<Integer,Integer>(SENSOR_INT) .period(1) .callable(new IncrementingCallable()) ) .build(); Asserts.succeedsEventually(new Runnable() { @Override public void run() { Integer val = entity.getAttribute(SENSOR_INT); assertTrue(val != null && val > 2, "val=" + val); } }); }
public static Builder builder() { return new Builder(); }
FunctionFeed extends AbstractFeed { public static Builder builder() { return new Builder(); } }
FunctionFeed extends AbstractFeed { public static Builder builder() { return new Builder(); } FunctionFeed(); protected  FunctionFeed(Builder builder); }
FunctionFeed extends AbstractFeed { public static Builder builder() { return new Builder(); } FunctionFeed(); protected  FunctionFeed(Builder builder); static Builder builder(); static Builder builder(String uniqueTag); }
FunctionFeed extends AbstractFeed { public static Builder builder() { return new Builder(); } FunctionFeed(); protected  FunctionFeed(Builder builder); static Builder builder(); static Builder builder(String uniqueTag); @SuppressWarnings("serial")
    static final ConfigKey<SetMultimap<FunctionPollIdentifier, FunctionPollConfig<?,?>>> POLLS; }