async def _create_upstream_applications(self):
loop = asyncio.get_event_loop()<EOL>for steam_name, ApplicationsCls in self.applications.items():<EOL><INDENT>application = ApplicationsCls(self.scope)<EOL>upstream_queue = asyncio.Queue()<EOL>self.application_streams[steam_name] = upstream_queue<EOL>self.application_futures[steam_name] = loop.create_task(<EOL>application(<EOL>upstream_queue.get,<EOL>partial(self.dispatch_downstream, steam_name=steam_name)<EOL>)<EOL>)<EOL><DEDENT>
Create the upstream applications.