Commit d8e1c875 authored by Him188's avatar Him188

add comments

parent f695c9f7
...@@ -32,8 +32,7 @@ import kotlin.coroutines.CoroutineContext ...@@ -32,8 +32,7 @@ import kotlin.coroutines.CoroutineContext
* *
* @see BotNetworkHandler * @see BotNetworkHandler
*/ */
internal class TIMBotNetworkHandler internal constructor(private val bot: Bot) : internal class TIMBotNetworkHandler internal constructor(private val bot: Bot) : BotNetworkHandler<TIMBotNetworkHandler.BotSocketAdapter>, PacketHandlerList() {
BotNetworkHandler<TIMBotNetworkHandler.BotSocketAdapter>, PacketHandlerList() {
override val coroutineContext: CoroutineContext = override val coroutineContext: CoroutineContext =
Dispatchers.Default + CoroutineExceptionHandler { _, e -> bot.logger.log(e) } + SupervisorJob() Dispatchers.Default + CoroutineExceptionHandler { _, e -> bot.logger.log(e) } + SupervisorJob()
...@@ -217,7 +216,7 @@ internal class TIMBotNetworkHandler internal constructor(private val bot: Bot) : ...@@ -217,7 +216,7 @@ internal class TIMBotNetworkHandler internal constructor(private val bot: Bot) :
return@coroutineScope return@coroutineScope
} }
// They should be called in sequence otherwise because packet is lock-free // They should be called in sequence because packet is lock-free
loginHandler.onPacketReceived(packet) loginHandler.onPacketReceived(packet)
this@TIMBotNetworkHandler.forEach { this@TIMBotNetworkHandler.forEach {
it.instance.onPacketReceived(packet) it.instance.onPacketReceived(packet)
...@@ -243,6 +242,24 @@ internal class TIMBotNetworkHandler internal constructor(private val bot: Bot) : ...@@ -243,6 +242,24 @@ internal class TIMBotNetworkHandler internal constructor(private val bot: Bot) :
} }
}*/ }*/
/* todo 修改为这个模式是否更好?
interface Pk
object TestPacket : Pk {
operator fun invoke(bot: UInt):ByteReadPacket = buildPacket {
}
}
override inline fun send(p: ByteReadPacket): UShort {
sendPacket{
// write packet head
// write version
// write bot qq number
writePacket(p)
}
}*/
override suspend fun sendPacket(packet: OutgoingPacket): Unit = withContext(coroutineContext) { override suspend fun sendPacket(packet: OutgoingPacket): Unit = withContext(coroutineContext) {
check(channel.isOpen) { "channel is not open" } check(channel.isOpen) { "channel is not open" }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment