Тип Void/Unit для вызова функции on_next без аргументов

Question

Я чувствую, что могу упустить что-то очень очевидное здесь, но в любом случае...

При использовании RxPY, есть ли эквивалент C# RX System.Reactive.Unit тип для вызова on_next функция без аргументов?

from rx import Observable

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

Если кому-то интересно, почему я могу это сделать, это потому, что я хочу, чтобы функция запуска в приведенном ниже коде вызывалась без 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

Ну да, я упустил что-то очевидное. Я могу просто подписаться, получить значение и игнорировать его с помощью лямбды.

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