python - 用于调用不带参数的 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"))

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

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()