假设我有一个看起来像这样的长时间运行的python函数？importrandomimporttimefromrximportObservabledefintns(x):y=random.randint(5,10)print(y)print('begin')time.sleep(y)print('end')returnx我希望能够将超时设置为1000ms。所以我正在做类似的事情，创建一个observable并通过上面的密集计算映射它。a=Observable.repeat(1).map(lambdax:intns(x))现在对于发出的每个值，如果它花费的时间超过1000毫秒，我想在到达1