rx-ruby

    0热度

    1回答

    我计划将来自tcp端口的传入数据视为来自“视图”的数据。我想设置一些RxRuby Observables,然后根据我从tcp端口获得的数据,选择适当的Observable并通过调用on_next方法发布一些内容。 下面的代码工作,但似乎笨拙。传递给Rx::Observable.create的块只是为传入它的observable设置一个实例变量。这不是一个巨大的锅炉板,但有些东西看起来不正确。我错过