Method sendAndGet

src/main/java/groovy/concurrent/Agent.java:184–196

Queues an update function and returns an Awaitable that completes with the new value after the update is applied. @param updateFn a function from current value to new value @return an awaitable holding the new value

(Function<T, T> updateFn)

     * @return an awaitable holding the new value
     */
    public Awaitable<T> sendAndGet(Function<T, T> updateFn) {
        Objects.requireNonNull(updateFn, "update function must not be null");
        CompletableFuture<T> cf = new CompletableFuture<>();
        updateExecutor.execute(() -> {
            try {
                T newVal = applyUpdate(updateFn);
                cf.complete(newVal);
            } catch (Throwable t) {
                cf.completeExceptionally(t);
            }
        });
        return GroovyPromise.of(cf);
    }

    /**
     * Shuts down the agent's update executor. No further updates will