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

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

主站蜘蛛池模板: 华安县| 车险| 辽宁省| 邵东县| 靖江市| 门头沟区| 福建省| 延安市| 淮安市| 米易县| 同心县| 都昌县| 格尔木市| 泰州市| 嵊州市| 习水县| 普洱| 共和县| 木里| 乌鲁木齐县| 钦州市| 南岸区| 和政县| 忻州市| 垣曲县| 谢通门县| 澄江县| 洪江市| 牟定县| 美姑县| 吴川市| 阳新县| 安乡县| 教育| 安康市| 楚雄市| 龙海市| 邯郸市| 达日县| 渝北区| 巴彦淖尔市|