Commit fe86353
committed
Merge pull request processing#2578 from kfeuz/Issue2577
Fixes NPE when writing to disconnected client, Issue processing#25771 file changed
Lines changed: 3 additions & 3 deletions
| Original file line number | Diff line number | Diff line change | |
|---|---|---|---|
@@ -310,8 +310,8 @@ public void run() { | |||
| 310 | 310 | public void write(int data) { // will also cover char | |
| 311 | 311 | int index = 0; | |
| 312 | 312 | while (index < clientCount) { | |
| 313 | - clients[index].write(data); | ||
| 314 | 313 | if (clients[index].active()) { | |
| 314 | + clients[index].write(data); | ||
| 315 | 315 | index++; | |
| 316 | 316 | } else { | |
| 317 | 317 | removeIndex(index); | |
@@ -323,8 +323,8 @@ public void write(int data) { // will also cover char | |||
| 323 | 323 | public void write(byte data[]) { | |
| 324 | 324 | int index = 0; | |
| 325 | 325 | while (index < clientCount) { | |
| 326 | - clients[index].write(data); | ||
| 327 | 326 | if (clients[index].active()) { | |
| 327 | + clients[index].write(data); | ||
| 328 | 328 | index++; | |
| 329 | 329 | } else { | |
| 330 | 330 | removeIndex(index); | |
@@ -336,8 +336,8 @@ public void write(byte data[]) { | |||
| 336 | 336 | public void write(String data) { | |
| 337 | 337 | int index = 0; | |
| 338 | 338 | while (index < clientCount) { | |
| 339 | - clients[index].write(data); | ||
| 340 | 339 | if (clients[index].active()) { | |
| 340 | + clients[index].write(data); | ||
| 341 | 341 | index++; | |
| 342 | 342 | } else { | |
| 343 | 343 | removeIndex(index); | |
0 commit comments