public void setDelegate()

in safeguard-impl/src/main/java/org/apache/safeguard/impl/asynchronous/BaseAsynchronousInterceptor.java [146:154]

• 9 lines of code
• 2 McCabe index (conditional complexity)

        public void setDelegate(final Future<T> delegate) {
            final Consumer<Future<T>> cancelledTask = cancelled.get();
            if (cancelledTask != null) {
                cancelledTask.accept(delegate);
            }
            after();
            this.delegate.set(delegate);
            this.latch.countDown();
        }