@Test public void testCallsOnFailureWithResultOfCallable() throws Exception { feed = FunctionFeed.builder() .entity(entity) .poll(new FunctionPollConfig<Integer, Integer>(SENSOR_INT) .period(1) .callable(Callables.returning(1)) .checkSuccess(Predicates.alwaysFalse()) .onSuccess(new AddOneFunction()) .onFailure(Functions.constant(-1))) .build(); EntityTestUtils.assertAttributeEqualsEventually(entity, SENSOR_INT, -1); }
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; }