<SYSTEM_TASK:>
Solve the following problem using Python, implementing the functions described below, one line at a time
<END_TASK>
<USER_TASK:>
Description:
 async def init_stream_from_settings(cfg: dict) -> Stream: """ 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. """

    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