@Test
public void shouldNotRetryInitialConnection() throws IOException {

    final Request request = mock(Request.class);
    when(request.execute()).thenThrow(new IOException("Initial connection failed"));
    when(RequestFactory.createRequest(uri, "GET")).thenReturn(request);
    final NoBackoffStrategy backoffStrategy = new NoBackoffStrategy();
    final NakadiReader<SomeEvent> nakadiReader = new NakadiReader<>(uri, RequestFactory, backoffStrategy, cursorManager, objectMapper, Collections.singleton(EVENT_NAME), Optional.empty(), Optional.empty(), SomeEvent.class, listener);
    expectedException.expect(IOException.class);
    expectedException.expectMessage(equalTo("Initial connection failed"));
    nakadiReader.run();
}