def METHOD_NAME(
        endpoint_path,
        input_doc_model=None,
):
    from fastapi import Request
    @app.api_route(
        path=f'/{endpoint_path.strip("/")}',
        methods=['GET'],
        summary=f'Streaming Endpoint {endpoint_path}',
    )
    async def streaming_get(request: Request):
        query_params = dict(request.query_params)
        req = DataRequest()
        req.header.exec_endpoint = endpoint_path
        if not docarray_v2:
            from docarray import Document
            req.data.docs = DocumentArray([Document.from_dict(query_params)])
        else:
            req.document_array_cls = DocList[input_doc_model]
            req.data.docs = DocList[input_doc_model]([input_doc_model(**query_params)])
        event_generator = _gen_dict_documents(await caller(req))
        return EventSourceResponse(event_generator)