public void onReadable()

in src/main/java/com/twitter/whiskey/nio/Socket.java [164:193]

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

    public void onReadable() {
        
        if (closed) {
            return;
        }

        Deque<ReadFuture> readQueue = getReadQueue();
        
        if (readQueue.isEmpty()) {
            reregister();
            return;
        }

        ReadFuture currentRead = readQueue.peek();
        assert (!currentRead.isDone());

        boolean complete;
        try {
            complete = currentRead.doRead(channel);
        } catch (IOException e) {
            close(e);
            return;
        }

        if (complete) {
            readQueue.poll();
        }

        reregister();
    }