Takatoshi Kondo redboltz

anonymous / unicast.scala

Created January 5, 2013 22:09

example of Concurent.unicast in Play 2.1

	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 / stdin_stream.hpp

Created April 9, 2011 03:47

boost::asio AsyncReadStream for console input

	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);
	}