|
@ -189,7 +189,7 @@ public final class ThreadManager { |
|
|
return null; |
|
|
return null; |
|
|
} |
|
|
} |
|
|
final DirectThread thread = threads.stream() |
|
|
final DirectThread thread = threads.stream() |
|
|
.filter(t -> t.getThreadId().equals(threadId)) |
|
|
|
|
|
|
|
|
.filter(t -> Objects.equals(t.getThreadId(), threadId)) |
|
|
.findFirst() |
|
|
.findFirst() |
|
|
.orElse(null); |
|
|
.orElse(null); |
|
|
if (thread != null) { |
|
|
if (thread != null) { |
|
|