@Test
public void testRead() throws IOException {

  EventLogHttpTransferListener listener = new EventLogHttpTransferListener();
  @SuppressWarnings("resource")
  InputStream in = new ObservableInputStream(new ByteArrayInputStream(new byte[10]), listener);
  in.read();
  in.read(new byte[2]);
  assertEquals(of(new Transferred(1), new Transferred(2)), listener.getEventLog());
}