forked from Cookies_Github_mirror/AquaDX
[F] Thread close
This commit is contained in:
@@ -148,7 +148,7 @@ class MaimaiFutari(private val port: Int = 20101) {
|
|||||||
|
|
||||||
try {
|
try {
|
||||||
while (true) {
|
while (true) {
|
||||||
val input = (reader.readLine() ?: continue).trim('\uFEFF')
|
val input = (reader.readLine() ?: if (Thread.interrupted()) break else continue).trim('\uFEFF')
|
||||||
if (input != "1,3") log.info("${socket.remoteSocketAddress} (${handler?.clientKey}) <<< $input")
|
if (input != "1,3") log.info("${socket.remoteSocketAddress} (${handler?.clientKey}) <<< $input")
|
||||||
val message = Msg.fromString(input)
|
val message = Msg.fromString(input)
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user