class Async::Container::Supervisor::Connection

def call(timeout: nil, **message)
	id = next_id
	calls[id] = ::Thread::Queue.new
	
	write(id: id, **message)
	
	return calls[id].pop(timeout: timeout)
ensure
	calls.delete(id)
end