@Test
public void testStarted() throws IOException {

  EventLogHttpTransferListener listener = new EventLogHttpTransferListener();
  final URI uri = URI.create("http://host/path");
  final Response response =
      new Response.Builder().request(new Request.Builder().url(uri.toURL()).build()).protocol(HTTP_1_1).code(200)
          .build();
  InputStream in =
      new ObservableResourceInputStream<Response>(new ByteArrayInputStream(new byte[0]), listener, response, 1l);
  in.close();
  assertEquals(of(new Started(uri, 1l), Closed.INSTANCE), listener.getEventLog());
}