65 lines
1.8 KiB
GDScript3
65 lines
1.8 KiB
GDScript3
|
static func catch_handler(
|
||
|
|
source : Observable,
|
||
|
|
handler : Callable
|
||
|
|
) -> Observable:
|
||
|
|
var subscribe = func(
|
||
|
|
observer : ObserverBase,
|
||
|
|
scheduler : SchedulerBase = null
|
||
|
|
) -> DisposableBase:
|
||
|
|
var d1 = SingleAssignmentDisposable.new()
|
||
|
|
var subscription = SerialDisposable.new()
|
||
|
|
|
||
|
|
subscription.disposable = d1
|
||
|
|
|
||
|
|
var on_error = func(err):
|
||
|
|
var result = RefValue.Null()
|
||
|
|
if GDRx.try(func():
|
||
|
|
result.v = handler.call(err, source)
|
||
|
|
) \
|
||
|
|
.catch("Error", func(e):
|
||
|
|
observer.on_error(e)
|
||
|
|
) \
|
||
|
|
.end_try_catch(): return
|
||
|
|
|
||
|
|
var d = SingleAssignmentDisposable.new()
|
||
|
|
subscription.disposable = d
|
||
|
|
d.disposable = result.v.subscribe(
|
||
|
|
observer, GDRx.basic.noop, GDRx.basic.noop, scheduler
|
||
|
|
)
|
||
|
|
|
||
|
|
d1.disposable = source.subscribe(
|
||
|
|
observer.on_next, on_error, observer.on_completed,
|
||
|
|
scheduler
|
||
|
|
)
|
||
|
|
return subscription
|
||
|
|
|
||
|
|
return Observable.new(subscribe)
|
||
|
|
|
||
|
|
static func catch_(handler) -> Callable:
|
||
|
|
var catch = func(source : Observable) -> Observable:
|
||
|
|
# """Continues an observable sequence that is terminated by an
|
||
|
|
# error with the next observable sequence.
|
||
|
|
#
|
||
|
|
# Examples:
|
||
|
|
# >>> var op = catch.call(ys)
|
||
|
|
# >>> var op = catch.call(func(ex, src): return ys(ex))
|
||
|
|
#
|
||
|
|
# Args:
|
||
|
|
# handler: Second observable sequence used to produce
|
||
|
|
# results when an error occurred in the first sequence, or an
|
||
|
|
# error handler function that returns an observable sequence
|
||
|
|
# given the error and source observable that occurred in the
|
||
|
|
# first sequence.
|
||
|
|
#
|
||
|
|
# Returns:
|
||
|
|
# An observable sequence containing the first sequence's
|
||
|
|
# elements, followed by the elements of the handler sequence
|
||
|
|
# in case an error occurred.
|
||
|
|
# """
|
||
|
|
if handler is Callable:
|
||
|
|
return catch_handler(source, handler)
|
||
|
|
else:
|
||
|
|
return GDRx.obs.catch_with_iterable(GDRx.util.Iter([source, handler]))
|
||
|
|
|
||
|
|
return catch
|