Nikita Khlebushkin
11/02/2020, 10:27 AMArkadii Ivanov
11/02/2020, 10:57 AMNikita Khlebushkin
11/02/2020, 12:00 PMOmar Mainegra
11/03/2020, 2:44 PMNikita Khlebushkin
11/03/2020, 2:57 PMOmar Mainegra
11/03/2020, 2:57 PMextension Observable where Element: AnyObject {
static func from(_ reaktiveObs: ReaktiveObservableWrapper<Element>) -> Observable<Element> {
return Observable<Element>.create { observer in
let disposable = reaktiveObs.subscribe(
isThreadLocal: false,
onError: { error in observer.onError(ReaktiveError(throwable: error)) },
onComplete: { observer.onCompleted() },
onNext: { value in observer.onNext(value) }
)
return Disposables.create { disposable.dispose() }
}
}
}
Nikita Khlebushkin
11/03/2020, 2:58 PMOmar Mainegra
11/03/2020, 2:59 PMArkadii Ivanov
11/03/2020, 3:05 PMOmar Mainegra
11/03/2020, 4:56 PMArkadii Ivanov
11/04/2020, 9:43 PMOmar Mainegra
11/04/2020, 10:01 PM