python method chaining without monads

functional.py

import functools
from joblib import Parallel, delayed

def compose2(f, g):
    return lambda x: g(f(x))

def compose(*fs):
    return functools.reduce(compose2, fs)

def pipe(x, *fs):
    return compose(*fs)(x)

def broadcast(fun):
    return lambda xs: (fun(x) for x in xs)

def pbroadcast(fun):
    return lambda xs: Parallel(n_jobs=16)(fun(x) for x in xs)

def fork(*fs):
    return lambda x: (f(x) for f in fs)