the changes is blocked/stuck in hasnext when we lose connection despite the signal changes.stop being set to true in another thread. Can we use the stop in the "do while" condition and exit when the signal is true.
` if(!stop) {
String row = "";
do {
row = getReader().readLine();
} while(row.length() == 0 && !stop);
if(!row.startsWith("{\"last_seq\":")) {
setNextRow(gson.fromJson(row, Row.class));
hasNext = true;
}
}`
the changes is blocked/stuck in hasnext when we lose connection despite the signal changes.stop being set to true in another thread. Can we use the stop in the "do while" condition and exit when the signal is true.
` if(!stop) {
String row = "";
do {
row = getReader().readLine();
} while(row.length() == 0 && !stop);