test_class.declarator: manager = new StreamManager()
test_class.modifier: private final
test_class.original_string: private final StreamManager manager = new StreamManager();
test_class.type: StreamManager
test_class.var_name: manager
test_class.file: akubra-core/src/test/java/org/akubraproject/impl/TestStreamManager.java
test_class.identifier: TestStreamManager
test_case.body: @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);
    }
test_case.class_method_signature: TestStreamManager.testManageOutputStream()
test_case.full_signature: @Test(dependsOnGroups = { "init" }) public void testManageOutputStream()
test_case.identifier: testManageOutputStream
test_case.invocations: manageOutputStream assertEquals getOpenOutputStreamCount close assertEquals getOpenOutputStreamCount
test_case.modifiers: @Test(dependsOnGroups = { "init" }) public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testManageOutputStream()
focal_class.declarator: log = LoggerFactory.getLogger(StreamManager.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger log = LoggerFactory.getLogger(StreamManager.class);
focal_class.type: Logger
focal_class.var_name: log
focal_class.declarator: listener
focal_class.modifier: protected final
focal_class.original_string: protected final CloseListener listener;
focal_class.type: CloseListener
focal_class.var_name: listener
focal_class.declarator: openOutputStreams
        = Collections.synchronizedSet(new HashSet<ManagedOutputStream>())
focal_class.modifier: protected final
focal_class.original_string: protected final Set<ManagedOutputStream> openOutputStreams
        = Collections.synchronizedSet(new HashSet<ManagedOutputStream>());
focal_class.type: Set<ManagedOutputStream>
focal_class.var_name: openOutputStreams
focal_class.declarator: openInputStreams
        = Collections.synchronizedSet(new HashSet<ManagedInputStream>())
focal_class.modifier: protected final
focal_class.original_string: protected final Set<ManagedInputStream> openInputStreams
        = Collections.synchronizedSet(new HashSet<ManagedInputStream>());
focal_class.type: Set<ManagedInputStream>
focal_class.var_name: openInputStreams
focal_class.file: akubra-core/src/main/java/org/akubraproject/impl/StreamManager.java
focal_class.identifier: StreamManager
focal_class.class_method_signature: StreamManager.StreamManager()
focal_class.full_signature: public  StreamManager()
focal_class.identifier: StreamManager
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.signature:  StreamManager()
focal_class.class_method_signature: StreamManager.manageOutputStream(BlobStoreConnection con, OutputStream stream)
focal_class.full_signature: public OutputStream manageOutputStream(BlobStoreConnection con, OutputStream stream)
focal_class.identifier: manageOutputStream
focal_class.modifiers: public
focal_class.parameters: (BlobStoreConnection con, OutputStream stream)
focal_class.return: OutputStream
focal_class.signature: OutputStream manageOutputStream(BlobStoreConnection con, OutputStream stream)
focal_class.class_method_signature: StreamManager.manageInputStream(BlobStoreConnection con, InputStream stream)
focal_class.full_signature: public InputStream manageInputStream(BlobStoreConnection con, InputStream stream)
focal_class.identifier: manageInputStream
focal_class.modifiers: public
focal_class.parameters: (BlobStoreConnection con, InputStream stream)
focal_class.return: InputStream
focal_class.signature: InputStream manageInputStream(BlobStoreConnection con, InputStream stream)
focal_class.class_method_signature: StreamManager.connectionClosed(BlobStoreConnection con)
focal_class.full_signature: public void connectionClosed(BlobStoreConnection con)
focal_class.identifier: connectionClosed
focal_class.modifiers: public
focal_class.parameters: (BlobStoreConnection con)
focal_class.return: void
focal_class.signature: void connectionClosed(BlobStoreConnection con)
focal_class.class_method_signature: StreamManager.getOpenOutputStreamCount()
focal_class.full_signature:  int getOpenOutputStreamCount()
focal_class.identifier: getOpenOutputStreamCount
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int getOpenOutputStreamCount()
focal_class.class_method_signature: StreamManager.getOpenInputStreamCount()
focal_class.full_signature:  int getOpenInputStreamCount()
focal_class.identifier: getOpenInputStreamCount
focal_class.parameters: ()
focal_class.return: int
focal_class.signature: int getOpenInputStreamCount()
focal_method.body: public OutputStream manageOutputStream(BlobStoreConnection con, OutputStream stream)
        throws IOException {
      ManagedOutputStream managed = new ManagedOutputStream(listener, stream, con);
      openOutputStreams.add(managed);
      return managed;
    }
focal_method.class_method_signature: StreamManager.manageOutputStream(BlobStoreConnection con, OutputStream stream)
focal_method.full_signature: public OutputStream manageOutputStream(BlobStoreConnection con, OutputStream stream)
focal_method.identifier: manageOutputStream
focal_method.invocations: add
focal_method.modifiers: public
focal_method.parameters: (BlobStoreConnection con, OutputStream stream)
focal_method.return: OutputStream
focal_method.signature: OutputStream manageOutputStream(BlobStoreConnection con, OutputStream stream)