Asyncronous Pipe - Python

async_pipe.py

import asyncio

async def async_pipe(init_value, *callables):
    """
        pipe for async function. work similar like toolz.pipe
        
        :parameter init_value: value or invoked function/async function
        :parameter callable: callable functions
        
    """
    if len(callables) > 0:
        if not all([callable(cal) for cal in callables]):
            raise ValueError("invalid value, must be callable")
    else:
        if asyncio.iscoroutine(init_value):
            return await init_value
        else:
            return init_value
    
    current_value = await init_value if asyncio.iscoroutine(init_value) else init_value
    
    for cal in callables:
        raw_value = cal(current_value)
        current_value = await raw_value if asyncio.iscoroutine(raw_value) else raw_value
        
    return current_value