async def METHOD_NAME() -> AsyncIterator[Tuple[_Src, LSPcomp]]:
    acc = {**self._local_cached.pre}
    self._local_cached.pre.clear()
    for client, (cached_items, length) in acc.items():
        items = (
            cached
            for item in cached_items
            if (
                cached := sanitize_cached(
                    context.cursor, comp=item, sort_by=None
                )
            )
        )
        yield _Src.from_stored, LSPcomp(
            client=client, local_cache=True, items=items, length=length
        )
    for co in as_completed((db(), lsp())):
        if comps := await co:
            yield comps
    async for lsp_comps in lsp_stream:
        yield _Src.from_query, lsp_comps