protonj2-client/src/main/java/org/apache/qpid/protonj2/client/futures/BalancedClientFuture.java [73:100]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                    synchronized (this) {
                        if (isComplete()) {
                            break;
                        } else if (getState() < COMPLETING) {
                            waiting++;
                            try {
                                wait(-diff / 1000000, (int) (-diff % 1000000));
                            } catch (InterruptedException e) {
                                Thread.interrupted();
                                throw e;
                            } finally {
                                waiting--;
                            }
                        }
                    }
                }
            }
        }

        if (error != null) {
            throw error;
        } else {
            return getResult();
        }
    }

    @Override
    public V get() throws InterruptedException, ExecutionException {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



protonj2-client/src/main/java/org/apache/qpid/protonj2/client/futures/ConservativeClientFuture.java [64:90]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
                synchronized (this) {
                    if (isComplete()) {
                        break;
                    } else if (getState() < COMPLETING) {
                        waiting++;
                        try {
                            wait(-diff / 1000000, (int) (-diff % 1000000));
                        } catch (InterruptedException e) {
                            Thread.interrupted();
                            throw e;
                        } finally {
                            waiting--;
                        }
                    }
                }
            }
        }

        if (error != null) {
            throw error;
        } else {
            return getResult();
        }
    }

    @Override
    public V get() throws InterruptedException, ExecutionException {
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -