@Test public void shouldSupportDisposeWithoutDelegate() throws Exception { connection.dispose(); }
@Override public synchronized void dispose() { disposed = true; if (delegate != null) { delegate.dispose(); } }
QueuingConnection implements Connection<I> { @Override public synchronized void dispose() { disposed = true; if (delegate != null) { delegate.dispose(); } } }
QueuingConnection implements Connection<I> { @Override public synchronized void dispose() { disposed = true; if (delegate != null) { delegate.dispose(); } }  }
QueuingConnection implements Connection<I> { @Override public synchronized void dispose() { disposed = true; if (delegate != null) { delegate.dispose(); } }  @Override synchronized void accept(I value); @Override synchronized void dispose(); }
QueuingConnection implements Connection<I> { @Override public synchronized void dispose() { disposed = true; if (delegate != null) { delegate.dispose(); } }  @Override synchronized void accept(I value); @Override synchronized void dispose();  }