Class StreamWrapper

arrow-pyarrow-integration-testing/tests/test_sql.py:172–177

class StreamWrapper(ArrowStreamExportable):
    def __init__(self, stream: ArrowStreamExportable) -> None:
        self.stream = stream

    def __arrow_c_stream__(self, requested_schema: Union[object, None] = None) -> object:
        return self.stream.__arrow_c_stream__(requested_schema=requested_schema)


@pytest.mark.parametrize("pyarrow_type", _supported_pyarrow_types, ids=str)