tursom/TursomServer
0
0
Fork 0
mirror of https://github.com/tursom/TursomServer.git synced 2024-12-29 14:30:55 +08:00
Code Issues Packages Projects Releases Wiki Activity

add AsyncChannelEnhance.kt

Browse Source
This commit is contained in:
tursom 2020-07-20 08:41:48 +08:00
parent e8b6d29c4e
commit ad50218e94
1 changed files with 23 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

23
AsyncSocket/src/main/kotlin/cn/tursom/channel/AsyncChannelEnhance.kt Normal file
View File

@ -0,0 +1,23 @@
package cn.tursom.channel
import cn.tursom.channel.enhance.ChannelReader
import cn.tursom.channel.enhance.ChannelWriter
import cn.tursom.channel.enhance.EnhanceChannel
import cn.tursom.channel.enhance.impl.*
import cn.tursom.core.buffer.ByteBuffer
fun AsyncChannel.reader(): ChannelReader<ByteBuffer> = ChannelReaderImpl(this)
fun AsyncChannel.writer(): ChannelWriter<ByteBuffer> = ChannelWriterImpl(this)
fun AsyncChannel.enhance(): EnhanceChannel<ByteBuffer, ByteBuffer> = EnhanceChannel(this)
fun ChannelReader<ByteBuffer>.lengthField(): ChannelReader<ByteBuffer> = LengthFieldBasedFrameReader(this)
fun ChannelWriter<ByteBuffer>.lengthField(): ChannelWriter<ByteBuffer> = LengthFieldPrependWriter(this)
fun EnhanceChannel<ByteBuffer, ByteBuffer>.lengthField(): EnhanceChannel<ByteBuffer, ByteBuffer> = LengthFieldChannel(this)
fun ChannelReader<ByteBuffer>.string() = StringReader(this)
fun ChannelWriter<ByteBuffer>.string() = StringWriter(this)
fun EnhanceChannel<ByteBuffer, ByteBuffer>.string() = StringChannel(this)
fun ChannelWriter<String>.stringObjectWriter(
toString: (obj: Any) -> String = { it.toString() }
): StringObjectWriter = StringObjectWriter(this, toString)