package Ġn vl . com . mv vm . utils . tran forms Ċ Ċ import Ġio . reactivex . Observable Ċ import Ġio . reactivex . Observable Source Ċ import Ġio . reactivex . Observable Transformer Ċ import Ġn vl . com . mv vm . data . remote . api . ApiError Ċ Ċ class ĠNever ApiError Transformer < T > Ġ: ĠObservable Transformer < T , ĠT > Ġ{ ĊĊĠĠĠ Ġoverride Ġfun Ġapply ( upstream : ĠObservable < T >): ĠObservable Source < T > Ġ{ ĊĠĠĠĠĠĠĠ Ġreturn Ġupstream . do OnError Ġ{ Ġt Ġ-> ĊĠĠĠĠĠĠĠĠĠĠĠ Ġrun Ġ{ ĊĠĠĠĠĠĠĠĠĠĠĠĠĠĠĠ Ġerror Action ?. invoke ( ApiError . from Throwable ( t )) ĊĠĠĠĠĠĠĠĠĠĠĠ Ġ} ĊĠĠĠĠĠĠĠ Ġ}. onError Resume Next Ġ{ Ġ_: ĠThrowable Ġ-> ĠObservable . empty () Ġ} ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġval Ġerror Action : Ġ(( ApiError ) Ġ-> ĠAny )? ĊĊĠĠĠ Ġconstructor () Ġ{ ĊĠĠĠĠĠĠĠ Ġerror Action Ġ= Ġnull ĊĠĠĠ Ġ} ĊĊĠĠĠ Ġconstructor ( error Action : Ġ( ApiError ) Ġ-> ĠAny ) Ġ{ ĊĠĠĠĠĠĠĠ Ġthis . error Action Ġ= Ġerror Action ĊĠĠĠ Ġ} Ċ }