PokedexServer.kt

PokedeServer.kt

class PokedexServer {

    private val port = 50052
    private var server: Server? = null

    @Throws(IOException::class)
    private fun start() {
        //...
        
        server = ServerBuilder.forPort(port)
            .addService(PokedexImpl())
            .build()
            .start()
    
        Runtime.getRuntime().addShutdownHook(object : Thread() {
            override fun run() {
                System.err.println("*** shutting down gRPC server since JVM is shutting down")
                this@PokedexServer.stop()
                System.err.println("*** server shut down")
            }
        })
    }

    private fun stop() {
        server?.shutdown()
    }

    internal class PokedexImpl() : PokedexGrpc.PokedexImplBase() {

        override fun getPokemon(request: PokedexRequest, responseObserver: StreamObserver<PokedexReply>) {
            
            val englishName = request.englishName
            
            // logic of find the pokemon info...

            val reply = PokedexReply.newBuilder()
                    .setId("pokemon ID" )
                    .setFrenchName("pokemon French name")
                    .setType("pokemon type")
                    .setImageUrl("pokemon image URL")
                    .build()
        
            responseObserver.onNext(reply)
            responseObserver.onCompleted()
        }
    }

    companion object {
        @Throws(IOException::class, InterruptedException::class)
        @JvmStatic
        fun main(args: Array<String>) {
            val server = PokedexServer()
            server.start()
            server.blockUntilShutdown()
        }
    }
}