Exerosis

package me.exerosis.example.lights;

import com.google.common.collect.Iterators;
import org.apache.commons.lang.WordUtils;
import org.bukkit.Bukkit;
import org.bukkit.DyeColor;
import org.bukkit.block.Block;
import org.bukkit.block.BlockState;
import org.bukkit.event.EventHandler;
import org.bukkit.event.Listener;

Exerosis

package me.exerosis.testing.kotlin

import com.mynt.network.implementation.read
import com.mynt.network.implementation.write
import com.mynt.network.providers.TCPSocketProvider
import kotlinx.coroutines.experimental.async
import kotlinx.coroutines.experimental.runBlocking
import java.net.InetSocketAddress
import java.nio.ByteBuffer
import java.nio.ByteBuffer.allocateDirect

Exerosis

package com.mynt.network.implementation.sequential

import com.mynt.network.ReadCoordinator
import com.mynt.network.implementation.Holder
import com.mynt.network.implementation.InProgressException
import java.nio.ByteBuffer
import java.nio.channels.CompletionHandler
import kotlin.coroutines.experimental.Continuation
import kotlin.coroutines.experimental.intrinsics.COROUTINE_SUSPENDED

Exerosis

package com.mynt.network.implementation.sequential

import com.mynt.network.ReadCoordinator
import com.mynt.network.implementation.Holder
import com.mynt.network.implementation.InProgressException
import java.nio.ByteBuffer
import java.nio.channels.CompletionHandler
import kotlin.coroutines.experimental.Continuation
import kotlin.coroutines.experimental.intrinsics.COROUTINE_SUSPENDED

Exerosis

package com.mynt.network

interface Connection : AutoCloseable {
    val read: Read
    val write: Write
    val isOpen: Boolean
}

Exerosis

package com.mynt.network

interface Connection : AutoCloseable {
    val read: Read
    val write: Write
    val isOpen: Boolean
}

Exerosis

package com.mynt.network.implementation.sequential

import com.mynt.network.ReadCoordinator
import java.nio.ByteBuffer
import java.nio.channels.CompletionHandler
import kotlin.coroutines.experimental.Continuation
import kotlin.coroutines.experimental.intrinsics.COROUTINE_SUSPENDED

class SequentialReadCoordinator(
        private val read: (ByteBuffer, CompletionHandler<Int, ByteBuffer>) -> Unit

Exerosis

package com.mynt.network.implementation

import com.mynt.network.Connection
import com.mynt.network.Read
import com.mynt.network.Write
import java.nio.ByteBuffer
import kotlin.coroutines.experimental.Continuation
import kotlin.coroutines.experimental.EmptyCoroutineContext
import kotlin.coroutines.experimental.intrinsics.suspendCoroutineUninterceptedOrReturn

Exerosis

package com.mynt.proxy.alpha.tcp.alpha.alpha.alpha.alpha

Exerosis

package com.mynt.proxy.alpha.tcp.alpha.alpha.alpha.alpha

import java.nio.ByteBuffer
import kotlin.coroutines.experimental.Continuation

interface ReadCoordinator {
    fun buffer(
            using: ByteBuffer,
            destination: ByteBuffer,
            continuation: Continuation<ByteBuffer>