Kotlin Native Reaktive -> RxSwift

ReaktiveToRxSwift.swift

import YourMPPFramework
import RxSwift

class KtError: Error {
    let error: KotlinThrowable
    
    init(_ error: KotlinThrowable) {
        self.error = error
    }
}

func toRxSwift<T>(_ source: ReaktiveSingleWrapper<T>) -> Single<T> {
    return Single<T>.create { observer -> Disposable in
        let disposable = source.subscribe(
            isThreadLocal: true,
            onSubscribe: nil,
            onError: { error in
                observer(.error(KtError(error)))
            },
            onSuccess: { value in
                observer(.success(value!))
            }
        )
        return Disposables.create { disposable.dispose() }
    }
}