### Question:
StreamManager { public InputStream manageInputStream(BlobStoreConnection con, InputStream stream) throws IOException { ManagedInputStream managed = new ManagedInputStream(listener, stream, con); openInputStreams.add(managed); return managed; } StreamManager(); OutputStream manageOutputStream(BlobStoreConnection con, OutputStream stream); InputStream manageInputStream(BlobStoreConnection con, InputStream stream); void connectionClosed(BlobStoreConnection con);  }### Answer:
@Test(dependsOnGroups = { "init" }) public void testManageInputStream() throws Exception { InputStream managed = manager.manageInputStream(null, new ByteArrayInputStream(new byte[0])); assertEquals(manager.getOpenInputStreamCount(), 1); managed.close(); assertEquals(manager.getOpenInputStreamCount(), 0); }