RxPY – 错误处理操作符

catch

当出现异常时，该操作符将终止源观察程序。

语法

catch(handler)

参数

handler：当源观察器出现错误时，这个观察器将被发射出来。

返回值

它将返回一个可观察变量，其中有错误前的源观察变量的值，然后是处理程序观察变量的值。

例子

from rx import of, operators as op
from datetime import date
test = of(1,2,3,4,5,6)
handler = of(11,12,13,14)
def casetest(e):
   if (e==4):
      raise Exception('err')
   else:
      return e
sub1 = test.pipe(
   op.map(lambda e : casetest(e)),
   op.catch(handler)
)
sub1.subscribe(lambda x: print("The value is {0}".format(x)),
on_error = lambda e: print("Error : {0}".format(e)))

在这个例子中，我们创建了一个异常，当来自观测器的源值为4时，所以第一个观测器在那里被终止，随后是来自处理程序的值。

输出

E:\pyrx>python testrx.py
The value is 1
The value is 2
The value is 3
The value is 11
The value is 12
The value is 13
The value is 14

retry

当出现错误时，该操作符将在源观测点上重试，一旦重试次数完成，它将终止。

语法

retry(count)

参数

count：如果源观测点出现错误，则重试的次数。

返回值

它将根据给定的重试次数，从源观测器中以重复的顺序返回一个观测器。

例子

from rx import of, operators as op
test = of(1,2,3,4,5,6)
def casetest(e):
   if (e==4):
     raise Exception('There is error cannot proceed!')
   else:
     return e
sub1 = test.pipe(
   op.map(lambda e : casetest(e)),
   op.retry(2)
)
sub1.subscribe(lambda x: print("The value is {0}".format(x)),
on_error = lambda e: print("Error : {0}".format(e)))

输出

E:\pyrx>python testrx.py
The value is 1
The value is 2
The value is 3
The value is 1
The value is 2
The value is 3
Error: There is error cannot proceed!