test_class.file: akubra-core/src/test/java/org/akubraproject/impl/TestManagedOutputStream.java
test_class.identifier: TestManagedOutputStream
test_case.body: @Test
    public void testCloseNotification() throws Exception {
      MockCloseListener listener = new MockCloseListener();
      ManagedOutputStream managed = new ManagedOutputStream(listener, new ByteArrayOutputStream(), null);
      managed.close();
      assertTrue(listener.getClosedSet().contains(managed));
    }
test_case.class_method_signature: TestManagedOutputStream.testCloseNotification()
test_case.full_signature: @Test public void testCloseNotification()
test_case.identifier: testCloseNotification
test_case.invocations: close assertTrue contains getClosedSet
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testCloseNotification()
focal_class.declarator: listener
focal_class.modifier: private final
focal_class.original_string: private final CloseListener listener;
focal_class.type: CloseListener
focal_class.var_name: listener
focal_class.declarator: con
focal_class.modifier: private final
focal_class.original_string: private final BlobStoreConnection con;
focal_class.type: BlobStoreConnection
focal_class.var_name: con
focal_class.declarator: closed = false
focal_class.modifier: private
focal_class.original_string: private boolean closed = false;
focal_class.type: boolean
focal_class.var_name: closed
focal_class.file: akubra-core/src/main/java/org/akubraproject/impl/ManagedOutputStream.java
focal_class.identifier: ManagedOutputStream
focal_class.class_method_signature: ManagedOutputStream.ManagedOutputStream(CloseListener listener, OutputStream stream, BlobStoreConnection con)
focal_class.full_signature:   ManagedOutputStream(CloseListener listener, OutputStream stream, BlobStoreConnection con)
focal_class.identifier: ManagedOutputStream
focal_class.parameters: (CloseListener listener, OutputStream stream, BlobStoreConnection con)
focal_class.signature:  ManagedOutputStream(CloseListener listener, OutputStream stream, BlobStoreConnection con)
focal_class.class_method_signature: ManagedOutputStream.getConnection()
focal_class.full_signature: public BlobStoreConnection getConnection()
focal_class.identifier: getConnection
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: BlobStoreConnection
focal_class.signature: BlobStoreConnection getConnection()
focal_class.class_method_signature: ManagedOutputStream.write(byte[] b, int off, int len)
focal_class.full_signature: @Override public void write(byte[] b, int off, int len)
focal_class.identifier: write
focal_class.modifiers: @Override public
focal_class.parameters: (byte[] b, int off, int len)
focal_class.return: void
focal_class.signature: void write(byte[] b, int off, int len)
focal_class.class_method_signature: ManagedOutputStream.close()
focal_class.full_signature: @Override public void close()
focal_class.identifier: close
focal_class.modifiers: @Override public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void close()
focal_class.superclass: extends FilterOutputStream
focal_method.body: @Override
    public void close() throws IOException {
      if (!closed) {
        super.close();
        closed = true;
        listener.notifyClosed(this);
      }
    }
focal_method.class_method_signature: ManagedOutputStream.close()
focal_method.full_signature: @Override public void close()
focal_method.identifier: close
focal_method.invocations: close notifyClosed
focal_method.modifiers: @Override public
focal_method.parameters: ()
focal_method.return: void
focal_method.signature: void close()