Skip to content

Instantly share code, notes, and snippets.

@Jire
Created May 17, 2016 16:03
Show Gist options
  • Save Jire/5f3b5146aa10dd28a2c341a0f57dc8d6 to your computer and use it in GitHub Desktop.
Save Jire/5f3b5146aa10dd28a2c341a0f57dc8d6 to your computer and use it in GitHub Desktop.
val group = NioEventLoopGroup()
val initializer = object : ChannelInitializer<SocketChannel>() {
override fun initChannel(ch: SocketChannel) {
ch.pipeline().addFirst(object : ChannelInboundHandlerAdapter() {
override fun channelRegistered(ctx: ChannelHandlerContext) {
ctx.writeAndFlush(buf)
println("Sent.")
}
})
}
}
for (i in 1..1) {
with(Bootstrap()) {
group(group)
channel(NioSocketChannel::class.java)
option(ChannelOption.SO_KEEPALIVE, true)
handler(initializer)
connect(addr)
}
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment