from tkinter import Tk, Label, Frame

from rx import from_
from rx import operators as _
from rx.subjects import Subject
from rx.concurrency import TkinterScheduler


def main():
    root = Tk()
    root.title("Rx for Python rocks")
    scheduler = TkinterScheduler(root)

    mousemove = Subject()

    frame = Frame(root, width=600, height=600)

    frame.bind("<Motion>", mousemove.on_next)

    text = 'TIME FLIES LIKE AN ARROW'

    def on_next(info):
        label, ev, i = info
        label.place(x=ev.x + i*12 + 15, y=ev.y)

    def handle_label(label, i):
        label.config(dict(borderwidth=0, padx=0, pady=0))

        mapper = _.map(lambda ev: (label, ev, i))
        delayer = _.delay(i*100)

        return mousemove.pipe(
            delayer,
            mapper
        )

    labeler = _.flat_mapi(handle_label)
    mapper = _.map(lambda c: Label(frame, text=c))

    from_(text).pipe(
        mapper,
        labeler
    ).subscribe_(on_next, on_error=print, scheduler=scheduler)

    frame.pack()
    root.mainloop()


if __name__ == '__main__':
    main()

@@ -35,28 +35,17 @@
 me%0A%0A
-from rx 
 import 
-from_
+rx
 %0Afro
@@ -69,17 +69,19 @@
 tors as 
-_
+ops
 %0Afrom rx
@@ -618,33 +618,35 @@
        mapper = 
-_
+ops
 .map(lambda ev: 
@@ -679,17 +679,19 @@
 layer = 
-_
+ops
 .delay(i
@@ -793,17 +793,19 @@
 beler = 
-_
+ops
 .flat_ma
@@ -834,17 +834,19 @@
 apper = 
-_
+ops
 .map(lam
@@ -879,16 +879,19 @@
 ))%0A%0A    
+rx.
 from_(te

Use ops instead of _