src to sink

gistfile1.py

from infix import or_infix as infix
from more_itertools import consumer


@infix
def to(src, sink):
    def _to():
        for x in src:
            sink.send(x)
    return _to


def source():
    yield from range(5)


@consumer
def sink():
    while True:
        x = yield
        print(x +1)


def main():
    plan = source() |to| sink()
    plan()


if __name__ == '__main__':
    main()

Output:

1
2
3
4
5

This doesn't compose well atm....doesn't yield output

I think there needs to be a distinction between sending and receiving that's not currently available