gatesn

from typing import AsyncIterator

import pyarrow as pa


class AsyncMessageReader(AsyncIterator[pa.Message]):
    """Wraps an async iterable of bytes into an async iterable of PyArrow IPC messages.
    
    From this it is possible to build an AsyncRecordBatchStreamReader.
    """

gatesn

from setuptools_zig import ZigExtension, zig_build_ext


def build(setup_kwargs):
    setup_kwargs["ext_modules"] = [ZigExtension("mypackage._mymodule", build_zig="path/to/build.zig")]
    setup_kwargs["cmdclass"] = {"build_ext": zig_build_ext}