public void onWriteable()

in src/main/java/com/twitter/whiskey/nio/Socket.java [196:225]

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

    public void onWriteable() {

        if (closed) {
            return;
        }

        Deque<WriteFuture> writeQueue = getWriteQueue();

        if (writeQueue.isEmpty()) {
            reregister();
            return;
        }

        WriteFuture currentWrite = writeQueue.peek();
        assert(!currentWrite.isDone());

        boolean complete;
        try {
             complete = currentWrite.doWrite();
        } catch (IOException e) {
            close(e);
            return;
        }

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

        reregister();
    }