package org.wasabi.http

​

import java.util.concurrent.Executors

import java.net.InetSocketAddress

import org.wasabi.app.AppConfiguration

import io.netty.bootstrap.ServerBootstrap

import io.netty.channel.nio.NioEventLoopGroup

import io.netty.channel.socket.nio.NioServerSocketChannel

import org.wasabi.app.AppServer

​

public class HttpServer(private val appServer: AppServer) {

​

    val bootstrap: ServerBootstrap

    val primaryGroup: NioEventLoopGroup

    val workerGroup:  NioEventLoopGroup

​

    {

        // Define worker groups

        primaryGroup = NioEventLoopGroup()

        workerGroup = NioEventLoopGroup()

​

        // Initialize bootstrap of server

        bootstrap = ServerBootstrap()

​

        bootstrap.group(primaryGroup, workerGroup)

        bootstrap.channel(javaClass<NioServerSocketChannel>())

        bootstrap.childHandler(NettyPipelineInitializer(appServer))

    }

​

    public fun start(wait: Boolean = true) {

        val channel = bootstrap.bind(appServer.configuration.port)?.sync()?.channel()

​