@Test public void testUsesExceptionHandlerOn4xxAndNoFailureHandler() throws Exception { server = BetterMockWebServer.newInstanceLocalhost(); for (int i = 0; i < 100; i++) { server.enqueue(new MockResponse() .setResponseCode(401) .setBody("Unauthorised")); } server.play(); feed = HttpFeed.builder() .entity(entity) .baseUrl(server.getUrl("/")) .poll(new HttpPollConfig<Integer>(SENSOR_INT) .period(100) .onSuccess(HttpValueFunctions.responseCode()) .onException(Functions.constant(-1))) .build(); assertSensorEventually(SENSOR_INT, -1, TIMEOUT_MS); server.shutdown(); }
public static Builder builder() { return new Builder(); }
HttpFeed extends AbstractFeed { public static Builder builder() { return new Builder(); } }
HttpFeed extends AbstractFeed { public static Builder builder() { return new Builder(); } HttpFeed(); protected  HttpFeed(Builder builder); }
HttpFeed extends AbstractFeed { public static Builder builder() { return new Builder(); } HttpFeed(); protected  HttpFeed(Builder builder); static Builder builder(); }
HttpFeed extends AbstractFeed { public static Builder builder() { return new Builder(); } HttpFeed(); protected  HttpFeed(Builder builder); static Builder builder(); static final Logger log; @SuppressWarnings("serial")
    static final ConfigKey<SetMultimap<HttpPollIdentifier, HttpPollConfig<?>>> POLLS; }