官术网_书友最值得收藏!

The from_callback operator

The from_callback operator is a higher order function. It returns a function that returns an observable. This observable emits a single item: the result of a callback function provided as a parameter of the operator. This callback function is called when the observable is being subscribed. The marble diagram of this operator is shown in the following figure:

Figure 4.10: The from_callback operator

Its prototype is as follows:

Observable.from_callback(func, selector=None)

The return value of the from_callback operator is a function. This function returns an observable, and must be called with the parameters to pass when func is called later on. The func callback is called when the of observable is being subscribed.

An optional selector parameter can be provided. This is a function called with the result of func as input parameters. When the selector parameter is provided, the item emitted on the observable is the return value of the selector parameter.

This operator does not accept a scheduler parameter. The whole call flow is always synchronous.

The following code is an example of its usage:

def foo(what, handler):
print("foo: {}".format(what))
handler("hello " + what)

callback = Observable.from_callback(foo)
cbk_obs = callback("world")
print("subscribing...")
cbk_obs.subscribe(
on_next=lambda i: print("item: {}".format(i)),
on_error=lambda e: print("error: {}".format(e)),
on_completed=lambda: print("completed")
)

When from_callback is called, a function is returned and stored in the callback variable. This callback operator is then invoked with the world parameter. The result of this call is an observable whose single item is the result of foo being called with the world parameter. Upon subscription, foo is called and a hello world item is received:

subscribing...
foo: world
item: hello world
completed

主站蜘蛛池模板: 榆林市| 合肥市| 历史| 万宁市| 固安县| 吉木萨尔县| 三都| 靖西县| 泊头市| 苍南县| 陕西省| 天气| 萝北县| 巴南区| 天峻县| 黑山县| 江陵县| 塔城市| 重庆市| 祁东县| 富民县| 平远县| 铜陵市| 白河县| 共和县| 澄迈县| 二连浩特市| 拜泉县| 西乡县| 乡宁县| 柯坪县| 义马市| 石景山区| 双鸭山市| 玉田县| 慈利县| 德令哈市| 漯河市| 千阳县| 滨海县| 洪江市|