@Test
public void testClose() throws IOException {

  EventLogHttpTransferListener listener = new EventLogHttpTransferListener();
  InputStream in = new ObservableInputStream(new ByteArrayInputStream(new byte[0]), listener);
  in.close();
  assertEquals(of(Closed.INSTANCE), listener.getEventLog());
}