unicast.scala

package controllers

import akka.actor._
import akka.pattern.ask
import akka.util.Timeout

import scala.concurrent.duration._
import scala.concurrent.Future

import play.api._

kikairoya

class stdin_stream: boost::noncopyable {
	typedef boost::function<void (const boost::system::error_code &, size_t bytes_transferred)> read_handler_type;
public:
	stdin_stream(boost::asio::io_service &io, HANDLE hin): io(io), hin(hin), hev(CreateEvent(0, 0, 0, 0)), handler(), buffer(0), size(0) {
		_beginthread(&stdin_stream::thread_handler_gateway, 0, this);
	}
	~stdin_stream() {
		buffer = 0;
		CloseHandle(hev);
	}