rxcocoa - rxswift tutorial

RxSwift minimal Observable.create example

Question

Actualmente estoy intentando hacer que RxSwift funcione. Y quiero crear un Observable personalizado. Pero creo que estoy haciendo algo mal.

He destilado lo que hago con esta muestra mínima:

import Foundation
import RxSwift
class Example
{
let exampleObservable : Observable<String> = Observable.create { (observer) in
observer.on(.Next("hello"))
observer.on(.Completed)
return AnonymousDisposable { }
}
let exampleObserver : AnyObserver<String>?
func run()
{
self.exampleObserver = exampleObservable.subscribeNext({ (text) -> Void in
print(text)
})
}
}
let ex = Example()
ex.run()

¿Es esto correcto? En el método run, el método subscribeNext se autocompleta de esa manera por XCode.

Pero cuando lo ejecuto, obtengo el siguiente error de compilación:

Cannot Invoke ''substribeNext'' with an argument list of type ((String) -> Void)

Answer 1

Es una buena idea usar rasgos cada vez que pueda, le sugiero que eche un vistazo a la documentación de RxSwift y la documentación de Rasgos Here.

Por ejemplo, al crear un método de llamada API, por lo general, devuelve un Single rasgo.

Entonces puede hacer algo como esto:

func getSomething() -> Single<YourType> {
return Single<YourType>.create { single in
//perform API call
//Then emmit success event
single(.success(YourType))
//Or error event
single(.error(Error))
return Disposables.create()
}
}

Estos son muchos otros rasgos que puede usar en diferentes casos con diferentes enfoques.

Answer 2

Esta implementación ha cambiado ligeramente con Swift 3 :

 func observableFunc() -> Observable<Bool> {
return Observable.create { observer in
self.apiClient.fetchData(callback: { results, error in
if let error = error {
observer.onError(error)
}
if let results = results {
observer.onNext(true)
}
})
return Disposables.create()
}
}

Answer 3

Puede usar RxExamples para comprender mejor RxSwift . Lo encontré en el repo RxSwift . Me ayudó a entender RxSwift.

Ok, intentemos enviar una solicitud simple usando Alamofire y RxSwift . Primero escribimos la función de solicitud:

 func getApi() -> Observable<AnyObject?> {
return create{ observer in
let request = Alamofire.request(.GET, "http://someapiurl.com", parameters: nil)
.response(completionHandler: { request, response, data, error in
if ((error) != nil) {
observer.on(.Error(error!))
} else {
observer.on(.Next(data))
observer.on(.Completed)
}
});
return AnonymousDisposable {
request.cancel()
}
}
}

getApi() método getApi() envía la solicitud y obtiene la respuesta del servidor usando Alamofire . RxSwift observador RxSwift para enviar mensajes de éxito o errores. Segundo, debemos llamar a esta función. Puede usar rx_tap para el botón:

class ViewController: UIViewController {
var disposeBag = DisposeBag()
override func viewDidLoad() {
super.viewDidLoad()
getApi()
// Set 3 attempts to get response
.retry(3)
// Set 2 seconds timeout
.timeout(2, MainScheduler.sharedInstance)
// Subscribe in background thread
.subscribeOn(Dependencies.sharedDependencies.backgroundWorkScheduler)
// Observe in main thread
.observeOn(Dependencies.sharedDependencies.mainScheduler)
// Subscribe on observer
.subscribe(
onNext: { data in
do {
let post = try NSJSONSerialization.JSONObjectWithData(data as! NSData, options: []) as! NSDictionary
print(post)
} catch {
print(NSString(data: data as! NSData, encoding: NSUTF8StringEncoding))
return
}
},
onError: { error in
print(error)
},
onCompleted: {
print("Completed")
},
onDisposed: {
print("Disposed")
}
)
.addDisposableTo(disposeBag)
}
}

Este es mi simple ejemplo. Espero que esto te ayude. ReactiveX es una gran oportunidad. Buena suerte en aprender RxSwift !

Answer 4

Sugeriría establecer un patio de recreo. El plugin CocoaPods playground proporciona una manera fácil de configurar el patio de recreo

gem install cocoapods-playgrounds
pod playgrounds RxSwift

Esto hace que sea más fácil y rápido usar RxSwift y mucho más rápido para probar cosas. En mi experiencia personal es la mejor manera de pulir tu comprensión