NIO client как отследить что сервер закрыл соединение или произошла потеря связи

import java.net.InetSocketAddress;
import java.net.Socket;
import java.nio.ByteBuffer;
import java.nio.channels.SelectionKey;
import java.nio.channels.Selector;
import java.nio.channels.SocketChannel;
import java.util.Scanner;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.BlockingQueue;
 
public class NoClient {
    
    static final int PORT = 2020;
    static final String ADDRESS = "192.168.0.101";
    private ByteBuffer buffer = ByteBuffer.allocate(16);
    
    private void run() throws Exception {
        
        SocketChannel channel = SocketChannel.open();
        channel.configureBlocking(false);
        Selector selector = Selector.open();
        channel.register(selector, SelectionKey.OP_CONNECT);
        channel.connect(new InetSocketAddress(ADDRESS, PORT));
        BlockingQueue<String> queue = new ArrayBlockingQueue<>(2);
        
        new Thread(() -> {
            Scanner scanner = new Scanner(System.in);
            while(true){
                String line = scanner.nextLine();
                if("q".equals(line)) {
                    System.exit(0);
                }
                try{
                    queue.put(line);
                } catch(InterruptedException e){
                    e.printStackTrace();
                }
                SelectionKey key = channel.keyFor(selector);
                key.interestOps(key.OP_WRITE);
                selector.wakeup();
            }
        }).start();
        
        while(true){
            
            selector.select();
            
            for(SelectionKey selectionKey : selector.selectedKeys()){
 
                  if (!selectionKey.isValid()) {
                      continue;
                    }
                
                if(selectionKey.isConnectable()){   //Если событие на подключение
                    channel.finishConnect();        //Подключаем
                    selectionKey.interestOps(selectionKey.OP_WRITE);  //Переключение ключа на запись
                } else if(selectionKey.isReadable()){  //Если запрос на чтение
                    buffer.clear();                    //Сбрасываем счетчик приёмного массива
                    channel.read(buffer);               //Читаем буффер
                    System.out.println("Recived = " + new String(buffer.array()));
                } else if(selectionKey.isWritable()){   //Если запрос на запись
                    String line = queue.poll();         //Смотри на состояние очереди
                    if(line != null) {                  //если очередь не пуста
                        channel.write(ByteBuffer.wrap(line.getBytes()));  //Оправляем данные
                    }
                    selectionKey.interestOps(selectionKey.OP_READ);  //Переключение ключа на чтение
                } 
                
            }
                
        }
        
        
    }
 
    
    public static void main(String[] args) throws Exception{
        new NoClient().run();
    }
 
}