import java.net.SocketAddress;
import java.net.StandardProtocolFamily;
import java.net.UnixDomainSocketAddress;
+import java.nio.channels.ClosedChannelException;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.nio.charset.Charset;
return () -> {
try {
return bufferedReader.readLine();
+ } catch (ClosedChannelException ignored) {
+ logger.trace("Line supplier has been interrupted.");
+ return null;
} catch (IOException e) {
logger.error("Error occurred while reading line", e);
return null;