wingfoil-python 4.0.1

python bindings for wingfoil - graph based stream processing framework
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28

#!/usr/bin/env python3

import math
from wingfoil import ticker, CustomStream


class MyStream(CustomStream):

    def cycle(self):
        value = 0
        for i, src in enumerate(self.upstreams()):
            value += src.peek_value() * math.pow(10, i)
        self.set_value(value)
        return True


period = 0.1 # seconds
source = ticker(period).count().logged("src")
(
    MyStream([source]*3)
        .map(lambda x : x * 0.01)
        .logged("out")
        .run(
            realtime = True,
            cycles = 5,
        )
)