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

The never and throw operators

The empty operator was discussed in Chapter 3, Functional Programming with ReactiveX. This operator is one of a triplet of similar operators: empty, never, and throw. The behavior of each of these operators should be clear from their names, as follows:

  • The empty operator creates an empty observable that completes immediately
  • The never operator creates an observable that never completes
  • The throw operator creates an observable that immediately completes on error

The following figure shows the marble diagram of the never operator:

Figure 4.5: The never operator

The following figure shows the marble diagram of the throw operator:

Figure 4.6: The throw operator

Their prototypes are as follows:

Observable.never()
Observable.throw(exception, scheduler=None)

Note that the never operator does not have a scheduler parameter. Since it never emits anything, there is no need for scheduling! The throw operator accepts any object in the exception parameter. If the provided value is an exception, then it is sent as-is. If the provided value is not an exception, then this value is encapsulated in an exception object before being notified. So, the observer of this observable will always receive an exception in its on_error handler.

The following code shows two ways to use the throw operator:

error = Observable.throw("Something wrong happened")
error.subscribe(
on_next=lambda i: print("item: {}".format(i)),
on_error=lambda e: print("error: {}".format(e)),
on_completed=lambda: print("completed")
)

exception = Observable.throw(NotImplementedError("I do nothing"))
exception.subscribe(
on_next=lambda i: print("item: {}".format(i)),
on_error=lambda e: print("error: {}".format(e)),
on_completed=lambda: print("completed")
)

The preceding code will provide the following results:

error: Something wrong happened
error: I do nothing
主站蜘蛛池模板: 赣州市| 东山县| 田林县| 浙江省| 扬州市| 朝阳县| 方山县| 竹北市| 平山县| 若羌县| 西安市| 万安县| 兰西县| 凌海市| 页游| 防城港市| 山东省| 隆化县| 金堂县| 徐汇区| 天等县| 八宿县| 井陉县| 桃源县| 宁河县| 阜阳市| 内江市| 威远县| 习水县| 东丽区| 茶陵县| 梅州市| 咸阳市| 万宁市| 舞钢市| 衡阳县| 信丰县| 泰来县| 平南县| 临沧市| 会宁县|