如何在Python中创建rx可观察对象

Question

我想创建很多可观察对象，每个都有一些id。下面是我尝试的：

class O():
    def __init__(self, id):
        self.id = id
    def callable(observer, scheduler, disposable):
        observer.on_next(id)

a = O(id='test')

source = rx.create(a.callable)

source.subscribe(
    on_next = lambda i: print(i),
    on_error = lambda e: print("Error Occurred: {0}".format(e)),
    on_completed = lambda: print("--- end of source ---"),
)

但我得到了：

Error Occurred: 'O' object has no attribute 'on_next'

我不能传递“静态”可调用函数，因为我想使用动态创建的可调用函数，每个可调用函数都有一个id