用于在没有参数的情况下调用on_next函数的Void/Unit类型

Question

我觉得我可能错过了一些很明显的东西，但无论如何

在使用RxPY时，是否有一种与C#RXSystem.Reactive.Unit类型等效的方法来调用on_next函数而不带参数

from rx import Observable

source = Observable.return_value(???)
source.subscribe(on_next=lambda: print("on_next called"))

如果有人想知道我为什么要这样做，那是因为我希望下面代码中的start函数在没有x参数的情况下被调用

def on_start(func):
    def func_wrapper():
        Observable.return("").subscribe(func)
    return func_wrapper

@on_start
def start(x):
    print(x)

start()

Answer 1

嗯，是的，我遗漏了一些明显的东西。我可以订阅、接收值并用lambda忽略它

def on_start(func):
    def func_wrapper():
        Observable.return_value("").subscribe(on_next=lambda _: func())
    return func_wrapper

@on_start
def start():
    print("doh")

start()