In [1]:

    

import karps as ks
import karps.functions as f
from karps.display import show_phase


    

In [2]:

    

o1 = ks.observable(1, name="a")
o2 = ks.observable(2, name="b")


    

In [3]:

    

o = o2 - o1


    

In [4]:

    

s = ks.session("test3")
comp = s.compute(o)


    

In [5]:

    

show_phase(comp, "initial")


    

In [6]:

    

show_phase(comp, "REMOVE_OBSERVABLE_BROADCASTS")


    

In [7]:

    

show_phase(comp, "MERGE_AGGREGATIONS")


    

In [8]:

    

show_phase(comp, "final")


    

In [9]:

    

comp.values()


    

    
Out[9]:





(int, int_value: 1
)

In [ ]: