private void select()

in core/src/main/java/com/epam/cme/mdp3/core/channel/MdpFeedWorker.java [166:178]

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

    private void select(final ByteBuffer byteBuffer, final MdpPacket mdpPacket) throws IOException {
        if (selector.isOpen() && selector.select() > 0) {
            Iterator<?> selectedKeys = selector.selectedKeys().iterator();
            while (selectedKeys.hasNext()) {
                final SelectionKey key = (SelectionKey) selectedKeys.next();
                selectedKeys.remove();

                if (key.isValid() && key.isReadable()) {
                    receiveMessageAndNotifySubscribers(byteBuffer, mdpPacket);
                }
            }
        }
    }