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
from wingfoil import ticker, constant, bimap
import wingfoil

period = 0.1

a = ticker(period * 2).count()
b = constant(0.7).sample(ticker(period))
(
    bimap(a, b, lambda a, b: a + b)
        .logged(">>")
        .run(realtime=False, duration=1.0)
)