@extensionmethod(Observable)
def subscribe_on(self, scheduler):

    source = self

    def subscribe(observer):
        m = SingleAssignmentDisposable()
        d = SerialDisposable()
        d.disposable = m

        def action(scheduler, state):
            d.disposable = ScheduledDisposable(scheduler, source.subscribe(observer))

        m.disposable = scheduler.schedule(action)
        return d

    return AnonymousObservable(subscribe)
Set the 'time' uniform within the shader
dataset/ETHPy150Open ReactiveX/RxPY/rx/linq/observable/subscribeon.py/subscribe_on--crossover with--dataset/ETHPy150Open gasman/shortcrust/examples/plasma.py/PlasmaShader.set_time