@Override
    public List<UTF8Row> next() throws Exception {
        // Node that System.in cannot be reopened, so don't close it.
        while (true) {
            if (reader == null) {
                return Collections.emptyList();
            }
            if (System.in.available() > 0) {
                break;
            }
            Thread.sleep(100);
        }
        String txt = reader.readLine();
        byte[] data = txt.getBytes("utf-8");
        return utf8JsonRowCreator.create(data);
    }
This class does not work properly, only used in tests.
indexr-server/src/main/java/io/indexr/server/rt/fetcher/ConsoleFetcher.java