Installation¶

Get Conveyor Streaming up and running in your Python environment.

Requirements¶

Python 3.8 or higher
asyncio support

Install with pip¶

pip install conveyor-streaming

Install with Poetry¶

poetry add conveyor-streaming

Development Installation¶

To install from source for development:

git clone https://github.com/ju-bezdek/conveyor.git
cd conveyor
pip install -e .

Or with Poetry:

git clone https://github.com/ju-bezdek/conveyor.git
cd conveyor
poetry install

Verify Installation¶

Test your installation:

import asyncio
from conveyor import single_task

@single_task
async def hello(name: str) -> str:
    return f"Hello, {name}!"

async def main():
    result = await hello("World").collect()
    print(result)  # ['Hello, World!']

if __name__ == "__main__":
    asyncio.run(main())

Optional Dependencies¶

For enhanced functionality, you may want to install additional packages:

aiofiles - For async file operations
aiohttp - For async HTTP requests
asyncpg - For PostgreSQL async database operations

Next Steps¶