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();  }
@Test public void shouldSupportDisposeWithoutDelegate() throws Exception { connection.dispose(); }