RxPy подписаться на повторяющуюся функцию обратного вызова - PullRequest
Новая
       36

RxPy подписаться на повторяющуюся функцию обратного вызова

0 голосов
/ 28 мая 2019

Я довольно плохо знаком с Rx и теперь испытываю следующую проблему: есть функция обратного вызова callback_b(self, value), которая неоднократно вызывается из ClassB, как я могу подписаться на эту функцию из ClassA function_a(self) и передать ей значение? 

import rx

class ClassA:
  def function_a(self):
    self.b = ClassB()
    observable = rx.create(self.b.callback_b) # idea to create an observable from a function
    observable.subscribe(lambda x: print("emitted value from callback_b " + x))

class ClassB:
  def callback_b(self, value):
    # callback consistently got triggered from time to time
    observable.on_next(value) # not sure how observable should be accessed, but idea to transmit value back to subscriber (ClassA)


ClassA().function_a() # creates instance of ClassB that eventually starts receiving data into callback_b and notify ClassA as it's observer
...