# FastAPI.

async def stream_json_list(items):
    for item in items:
        yield item
        await asyncio.sleep(4.0)  # To demonstrate, visibly, the successful implementation.


async def get_media_metadata(tags: Optional[Set[str]] = Query(None,
                                                              description="Tags to filter on")):
    metadata = metadata_repository.get_metadata_for_items_by_tags(tags=tags)
    return StreamingResponse(
        stream_json_list(m.json() for m in metadata),
        media_type='application/json'
    )