public boolean provide()

in src/main/java/com/twitter/whiskey/futures/ReactiveFuture.java [30:44]

• 12 lines of code
• 6 McCabe index (conditional complexity)

    public boolean provide(final E element) throws RuntimeException {

        if (isDone()) return false;

        synchronized(this) {
            if (isDone()) return false;
            if (!streaming || (observers.isEmpty() && iterators.isEmpty())) {
                accumulate(element);
                return true;
            }

            dispatch(element);
            return true;
        }
    }