code: async def init_stream_from_settings(cfg: dict) -> Stream:
      
      cfg_name = cfg["active_stream"]
      stream_init_kwargs = cfg["streams"][cfg_name]
      stream = Stream(**stream_init_kwargs)
      await stream.connect()
      _stream_storage.push(cfg_name, stream)
      return stream
docs: Shortcut to create Stream from configured settings.
  
      Will definitely fail if there is no meaningful configuration provided. Example of such is::
  
          {
              "streams": {
                  "rabbitmq": {
                      "transport": "sunhead.events.transports.amqp.AMQPClient",
                      "connection_parameters": {
                          "login": "guest",
                          "password": "",
                          "host": "localhost",
                          "port": 5672,
                          "virtualhost": "video",
                      },
                      "exchange_name": "video_bus",
                      "exchange_type": "topic",
                      "global_qos": None,
                  },
                  "kafka": {},
              },
              "active_stream": "rabbitmq",
          }
  
      :return: Instantiated Stream object.