Qiita記事 yield fromへ統一

main.py

from kivy.clock import Clock

def start_gen(gen):
    def step_gen(*args, **kwargs):
        try:
            gen.send((args, kwargs, ))(step_gen)
        except StopIteration:
            pass
    try:
        gen.send(None)(step_gen)
    except StopIteration:
        pass


def thread(func, *args, **kwargs):
    from threading import Thread
    return_value = None
    is_finished = False
    def wrapper(*args, **kwargs):
        nonlocal return_value, is_finished
        return_value = func(*args, **kwargs)
        is_finished = True
    Thread(target=wrapper, args=args, kwargs=kwargs).start()
    while not is_finished:
        yield from sleep(3)
    return return_value


def sleep(duration):
    return (yield lambda step_gen: Clock.schedule_once(step_gen, duration))


def event(ed, name):
    bind_id = None
    step_gen = None
    def bind(step_gen_):
        nonlocal bind_id, step_gen
        bind_id = ed.fbind(name, callback)
        assert bind_id > 0  # bindingに成功したか確認
        step_gen = step_gen_
    def callback(*args, **kwargs):
        ed.unbind_uid(name, bind_id)
        step_gen(*args, **kwargs)
    return (yield bind)


from kivy.app import App
from kivy.lang import Builder
from kivy.factory import Factory


KV_CODE = '''
Button:
'''

class SampleApp(App):
    def build(self):
        return Builder.load_string(KV_CODE)
    def on_start(self):
        start_gen(self.some_task())
    def some_task(self):
        def heavy_task():
            import time
            for i in range(5):
                time.sleep(1)
                print(i)
        button = self.root
        button.text = 'start heavy task'
        yield from event(button, 'on_press')
        button.text = 'running...'
        yield from thread(heavy_task)
        button.text = 'done'


if __name__ == '__main__':
    SampleApp().run()