|
@@ -39,12 +39,7 @@ public abstract class ThreadedParser implements Parser {
|
39
|
39
|
public void connect() {
|
40
|
40
|
synchronized (controlThreadLock) {
|
41
|
41
|
if (controlThread == null) {
|
42
|
|
- controlThread = new Thread(new Runnable() {
|
43
|
|
- @Override
|
44
|
|
- public void run() {
|
45
|
|
- ThreadedParser.this.run();
|
46
|
|
- }
|
47
|
|
- }, "Parser Thread");
|
|
42
|
+ controlThread = new Thread(this::run, "Parser Thread");
|
48
|
43
|
controlThread.start();
|
49
|
44
|
} else {
|
50
|
45
|
// To ensure correct internal state, parsers must be recreated for
|