| 1139 | | let len = sis.available(); |
| 1140 | | if (len <= 0) |
| 1141 | | return; |
| 1142 | | let data = sis.read(len); |
| 1143 | | let lines = data.split(/\n/); |
| 1144 | | if (lines.length > 2) { |
| 1145 | | lines[0] = buf + lines[0]; |
| 1146 | | for (let [, line] in Iterator(lines.slice(0, -1))) { |
| 1147 | | try { |
| 1148 | | onMsg(JSON.parse(line), line); |
| 1149 | | } catch (e) {} |
| | 1139 | try { |
| | 1140 | let len = sis.available(); |
| | 1141 | if (len <= 0) |
| | 1142 | return; |
| | 1143 | let data = sis.read(len); |
| | 1144 | let lines = data.split(/\n/); |
| | 1145 | if (lines.length > 2) { |
| | 1146 | lines[0] = buf + lines[0]; |
| | 1147 | for (let [, line] in Iterator(lines.slice(0, -1))) { |
| | 1148 | try { |
| | 1149 | onMsg(JSON.parse(line), line); |
| | 1150 | } catch (e) {} |
| | 1151 | } |
| | 1152 | buf = lines.slice(-1)[0]; |
| | 1153 | } else { |
| | 1154 | buf += data; |