public void release()

in src/main/java/com/twitter/whiskey/futures/ReactiveFuture.java [49:63]

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

    public void release() {

        if (streaming) return;

        synchronized (this) {
            if (streaming) return;
            streaming = true;

            if (observers.isEmpty() && iterators.isEmpty()) return;
            drained = true;
            for (final E element : drain()) {
                dispatch(element);
            }
        }
    }