In [1]:

    

from streamz import Stream
source = Stream()

s = source.sliding_window(2).map(sum)
s.rate_limit(0.5).sink(source.emit)

L = s.sink_to_list()
s.sink(print)


    

    
Out[1]:





<sink: print>

In [2]:

    

source.emit(0)
source.emit(1)


    

    




2
1






    
Out[2]:





<tornado.concurrent.Future at 0x4e65d30>






    




3
5
8
13
21
34
55
89
144
233
377
610
987
1597
2584
4181
6765
10946
17711
28657
46368
75025
121393
196418
317811
514229
832040
1346269
2178309
3524578
5702887
9227465
14930352
24157817
39088169
63245986
102334155
165580141
267914296
433494437
701408733
1134903170

In [ ]: