import java.net.InetSocketAddress;
import java.net.Socket;
import java.nio.ByteBuffer;
import java.nio.channels.ServerSocketChannel;
import java.nio.channels.SocketChannel;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

import org.msgpack.core.MessagePack;
import org.msgpack.core.MessageUnpacker;

public class ChannelUnpackerTest {
	public static void main(String[] args) throws Exception {
		try (ServerSocketChannel serverChannel = ServerSocketChannel.open()) {
			serverChannel.socket().bind(new InetSocketAddress("localhost", 7777));
			ExecutorService pool = Executors.newFixedThreadPool(10);
			for (int i = 0; i < 10; i++) {
				pool.execute(() -> {
					try {
						SocketChannel channel = serverChannel.accept();
						channel.write(ByteBuffer.wrap(new byte[200]));
					} catch (Exception e) {
						//nothing
					}
				});
			}

			try (Socket socket = new Socket("localhost", 7777)) {
				MessageUnpacker unpacker = MessagePack.newDefaultUnpacker(socket.getInputStream());
				unpacker.readPayload(ByteBuffer.allocate(128));
				System.out.println("read from socket");
			}

			try (SocketChannel channel = SocketChannel.open(new InetSocketAddress("localhost", 7777))) {
				MessageUnpacker unpacker = MessagePack.newDefaultUnpacker(channel);
				unpacker.readPayload(ByteBuffer.allocate(128));
				System.out.println("read from channel");
			}
		}
	}
}