Function read_docs

examples/acouchbase/vector_search_async.py:93–96

()

def read_docs():
    with open(TEST_VECTOR_SEARCH_DOCS_PATH) as input:
        while line := input.readline():
            yield json.loads(line)


async def load_docs(root: str, collection: AsyncCollection) -> List[str]: