class Async::Container::Supervisor::Connection

def run(target)
	self.each do |message|
		if id = message.delete(:id)
			if call = @calls[id]
				# Response to a call:
				call.push(**message)
			else
				# Incoming call:
				Call.dispatch(self, target, id, message)
			end
		else
			Console.error(self, "Unknown message:", message)
		end
	end
end