@Override
    public synchronized void onCompleted() {
        doneFuture.set(null);
    }
@Test
    public void onCompleted() {
        completeObserver.onCompleted();
        ListenableFuture<Void> future = completeObserver.getCompletionFuture();
        assertNotNull(future);
    }