public boolean finish()

in src/main/java/com/twitter/whiskey/futures/ReactiveFuture.java [68:90]

• 21 lines of code
• 5 McCabe index (conditional complexity)

    public boolean finish() {

        if (drained) {
            boolean result = set(null);
            if (result) {
                for (final Observer observer : observers) {
                    observer.getExecutor().execute(new Runnable() {
                        @Override
                        public void run() {
                            observer.onComplete();
                        }
                    });
                }

                for (final StreamingIterator iterator : iterators) {
                    iterator.queue(SENTINEL);
                }
            }
            return result;
        } else {
            return complete();
        }
    }