github-repos/mirai
1
0
Fork 0
mirror of https://github.com/mamoe/mirai.git synced 2025-02-01 03:50:18 +08:00
Code Issues Packages Projects Releases Wiki Activity

Remove inline modifier

Browse Source
This commit is contained in:
Him188 2020-02-07 12:30:26 +08:00
parent 147254cecd
commit a7857f147d
3 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
mirai-core/src/androidMain/kotlin/net/mamoe/mirai/utils/io/PlatformSocket.kt
View File

@ -30,7 +30,7 @@ actual class PlatformSocket : Closeable {
@PublishedApi @PublishedApi
internal lateinit var readChannel: BufferedInputStream internal lateinit var readChannel: BufferedInputStream
actual suspend inline fun send(packet: ByteArray, offset: Int, length: Int) { actual suspend fun send(packet: ByteArray, offset: Int, length: Int) {
withContext(Dispatchers.IO) { withContext(Dispatchers.IO) {
writeChannel.write(packet, offset, length) writeChannel.write(packet, offset, length)
writeChannel.flush() writeChannel.flush()
@ -40,7 +40,7 @@ actual class PlatformSocket : Closeable {
/** /**
* @throws SendPacketInternalException * @throws SendPacketInternalException
*/ */
actual suspend inline fun send(packet: ByteReadPacket) { actual suspend fun send(packet: ByteReadPacket) {
withContext(Dispatchers.IO) { withContext(Dispatchers.IO) {
try { try {
writeChannel.writePacket(packet) writeChannel.writePacket(packet)
@ -54,7 +54,7 @@ actual class PlatformSocket : Closeable {
/** /**
* @throws ReadPacketInternalException * @throws ReadPacketInternalException
*/ */
actual suspend inline fun read(): ByteReadPacket { actual suspend fun read(): ByteReadPacket {
return withContext(Dispatchers.IO) { return withContext(Dispatchers.IO) {
try { try {
readChannel.readPacketAtMost(Long.MAX_VALUE) readChannel.readPacketAtMost(Long.MAX_VALUE)

6
mirai-core/src/commonMain/kotlin/net.mamoe.mirai/utils/io/PlatformSocket.kt
View File

@ -15,17 +15,17 @@ expect class PlatformSocket() : Closeable {
/** /**
* @throws SendPacketInternalException * @throws SendPacketInternalException
*/ */
suspend inline fun send(packet: ByteArray, offset: Int = 0, length: Int = packet.size - offset) suspend fun send(packet: ByteArray, offset: Int = 0, length: Int = packet.size - offset)
/** /**
* @throws SendPacketInternalException * @throws SendPacketInternalException
*/ */
suspend inline fun send(packet: ByteReadPacket) suspend fun send(packet: ByteReadPacket)
/** /**
* @throws ReadPacketInternalException * @throws ReadPacketInternalException
*/ */
suspend inline fun read(): ByteReadPacket suspend fun read(): ByteReadPacket
val isOpen: Boolean val isOpen: Boolean
} }

6
mirai-core/src/jvmMain/kotlin/net/mamoe/mirai/utils/io/PlatformSocket.kt
View File

@ -34,7 +34,7 @@ actual class PlatformSocket : Closeable {
@PublishedApi @PublishedApi
internal lateinit var readChannel: BufferedInputStream internal lateinit var readChannel: BufferedInputStream
actual suspend inline fun send(packet: ByteArray, offset: Int, length: Int) { actual suspend fun send(packet: ByteArray, offset: Int, length: Int) {
withContext(Dispatchers.IO) { withContext(Dispatchers.IO) {
writeChannel.write(packet, offset, length) writeChannel.write(packet, offset, length)
writeChannel.flush() writeChannel.flush()
@ -44,7 +44,7 @@ actual class PlatformSocket : Closeable {
/** /**
* @throws SendPacketInternalException * @throws SendPacketInternalException
*/ */
actual suspend inline fun send(packet: ByteReadPacket) { actual suspend fun send(packet: ByteReadPacket) {
withContext(Dispatchers.IO) { withContext(Dispatchers.IO) {
try { try {
writeChannel.writePacket(packet) writeChannel.writePacket(packet)
@ -58,7 +58,7 @@ actual class PlatformSocket : Closeable {
/** /**
* @throws ReadPacketInternalException * @throws ReadPacketInternalException
*/ */
actual suspend inline fun read(): ByteReadPacket { actual suspend fun read(): ByteReadPacket {
return withContext(Dispatchers.IO) { return withContext(Dispatchers.IO) {
try { try {
readChannel.readPacketAtMost(Long.MAX_VALUE) readChannel.readPacketAtMost(Long.MAX_VALUE)