### Question:
StreamManager { public OutputStream manageOutputStream(BlobStoreConnection con, OutputStream stream) throws IOException { ManagedOutputStream managed = new ManagedOutputStream(listener, stream, con); openOutputStreams.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 testManageOutputStream() throws Exception { OutputStream managed = manager.manageOutputStream(null, new ByteArrayOutputStream()); assertEquals(manager.getOpenOutputStreamCount(), 1); managed.close(); assertEquals(manager.getOpenOutputStreamCount(), 0); }