public void close()

in src/main/java/com/twitter/http2/Pipe.java [135:146]

• 11 lines of code
• 3 McCabe index (conditional complexity)

    public void close() {
        synchronized (this) {
            if (closed) {
                return;
            }
            closed = true;
        }

        while (!receiveQueue.isEmpty()) {
            receiveQueue.poll().setFailure(PIPE_CLOSED);
        }
    }