class Async::Container::Supervisor::Connection

def each

def each
	while message = self.read
		yield message
	end
end