Installation

(Not Uploaded yet)

Usage

Like Stream Api in Java but slightly different in details

from streampy import *

Stream.of([1, 2, 3])
    .map(lambda x: x * x)
    .for_each(lambda x: print(x))

This api supports various Iterable object in Python, like list, tuple and generator. As a result, you can call it in these ways:

from streampy import *

Stream.of((1, 2, 3))
    .map(lambda x: x * x)
    .for_each(lambda x: print(x))

# OR

def gen():
    l = [1, 2, 3]
    for i in l:
        yield i

g = gen()

Stream.of(g)
    .map(lambda x: x * x)
    .for_each(lambda x: print(x))

# OR

Stream.of(open("foo.txt", 'r'))
    .map(lambda x: x * x)
    .for_each(lambda x: print(x))

Contribution

Welcome to contribute to the project. The project is written in C. If you cannot understand Python’s C API, you can refer to the code in python package. It is the streamcpy implemented in python but will not be packed in the package. Here is the detailed description for each directory or file:

• benchmark: a roughly comparison between Python and C++ (Python wins)

• build: the built file of the package (.pyd for Windows and .so for Linux or Mac)

• modules: the source code for streamcpy in C

• python: the source code for streamcpy in python and only for reference

• vs: the project files for Visual Studio

• setup.py: the setup file for python

• streamcpy.c: the entrance file for streamcpy package

• streamcpy.pyi: the .pyi file for streamcpy package

python setup.py build

python setup.py install