PyStreams

A library to filter out your data from your lists. Useful for streaming data and store data into storages. An Idea from Java8 Streams.

Examples

import streams

# Filter data
list_of_data = [1, 2, 3, 5, 7]
actuals = streams.Stream.of(list_of_data).filter(lambda x: x > 5).collect(print)
assert actuals == [7]


# Map data
list_of_data = [1, 2, 3, 5, 7]
actuals = streams.Stream.of(list_of_data).map(lambda x: x * 5).collect(print)
assert actuals == [5, 10, 15, 25, 35]


# map and filter data
list_of_data = [1, 2, 3, 5, 7]
actuals = streams.Stream.of(list_of_data).map(lambda x: x * 5). \
                    filter(lambda x: x > 25).collect(print)
assert actuals == [35]

# find first
list_of_data = [1, 2, 3, 5, 7]
actuals = streams.Stream.of(list_of_data).map(lambda x: x * 5).find_first(). \
                        collect(print)
assert actuals == [5]

# using for_each 
list_of_data = [4, 5, 6, 1335]
actuals = streams.Stream.of(list_of_data).map(lambda x: x * 5). \
                        for_each(print)    
Output:

20
25
30
6675

# using sort in lists
list_of_data = [23, 2, 1, 44]
actuals = streams.Stream.of(list_of_data).sort(). \
                        for_each(print)
Output:
1
2
23
44

# average
list_of_data = [23, 2, 1, 44]
actuals = streams.Stream.of(list_of_data).average(). \
                        for_each(print)
Output:
17.5

# Using limits
list_of_data = [23, 2, 1, 44]
actuals = streams.Stream.of(list_of_data).limit(2).collect(print)
Output:
[23, 2]

# Using Sum
list_of_data = [1, 2, 3, 5, 7]
actuals = streams.Stream.of(list_of_data). \
    sum().collect(print)

Output:
18
Note:- if a element has a string. It won't calculate, even it is "7".

# 
reset and generate data
list_of_data = [1, 2, 3, 5, 7]
actuals = streams.Stream.of(list_of_data).reset(). \
    generate(element=int("1"), times=4).sum().collect(print)
Output:
4